Support for schema id in header

[rayokota]

What

Checklist

• Contains customer facing changes? Including API/behavior changes
• Did you add sufficient unit test and/or integration test coverage for this PR?
  • If not, please explain why it is not required

References

JIRA:

Test & Review

Open questions / Follow-ups

[confluent-cla-assistant]

🎉 All Contributor License Agreements have been signed. Ready to merge.
_{Please push an empty commit if you would like to re-run the checks to verify CLA status for all contributors.}

[Copilot]

Pull Request Overview

This PR adds support for including the schema ID (or GUID) in the message header as well as updates multiple tests and service‐side logic accordingly. Key changes include:

• New serialization logic (via header_schema_id_serializer and dual_schema_id_deserializer) that uses a SchemaId object carrying both numeric and GUID values.
• Updates to schema caching and lookup in SchemaRegistryClient to support GUID‐based queries.
• New and updated test cases for schema ID/GUID in the header for protobuf, JSON, and Avro serdes.

Reviewed Changes

Copilot reviewed 15 out of 15 changed files in this pull request and generated 2 comments.

File	Description
tests/schema_registry/*.py	Test updates to exercise schema ID in header via new serializer configuration
src/confluent_kafka/schema_registry/serde.py	New SchemaId class to handle both numeric ID and GUID conversions
src/confluent_kafka/schema_registry/schema_registry_client.py	Changes in schema cache and registered schema functions to support GUID storage and lookup
src/confluent_kafka/schema_registry/init.py	Addition of header_schema_id_serializer and related serializer/deserializer changes

[sonarqube-confluent]

• 75.20% Coverage on New Code (is less than 80.00%)

Analysis Details

20 Issues

• 0 Bugs
• 0 Vulnerabilities
• 20 Code Smells

Coverage and Duplications

• 75.20% Coverage (61.10% Estimated after merge)
• No duplication information (1.00% Estimated after merge)

Project ID: confluent-kafka-python

View in SonarQube