confluent-kafka-python icon indicating copy to clipboard operation
confluent-kafka-python copied to clipboard

Set avro/json schema on use.latest.version=True

Open ifnesi opened this issue 1 year ago • 2 comments

The current AvroSerializer (src/confluent_kafka/schema_registry/avro.py) and JSONSerializer (src/confluent_kafka/schema_registry/json_schema.py) classes do not override the schema when use.latest.schema is set to True, it currently only returns the schema_id. This PR is to address that.

Please notice the same behaviour happens with ProtobufSerializer (src/confluent_kafka/schema_registry/protobuf.py), however not sure how use.latest.schema could work with Protobuf schemas as it needs to be "compiled" and the SR stores the "uncompiled" version of it. Maybe we should drop that configuration parameter out?

ifnesi avatar Jan 17 '24 13:01 ifnesi

CLA assistant check
All committers have signed the CLA.

cla-assistant[bot] avatar Jan 17 '24 13:01 cla-assistant[bot]

@rayokota - You need to sign the CLA for the PR to get merged.

pranavrth avatar Jun 19 '24 08:06 pranavrth