'Change schema name strategy in confluent Kafka
I am using confluent Kafka and schema registry and I cannot figure out a way to have custom schema name in python. From this blog I got how to do it in Java, but do not have any idea what the equivalent of:
properties.setProperty("value.subject.name.strategy", TopicRecordNameStrategy.class.getName());
would be. Adding the property 'key.subject.name.strategy': 'io.confluent.kafka.serializers.subject.RecordNameStrategy'
in the AvroProducer()
does not help. What am I missing?
Solution 1:[1]
The Python client doesn't currently expose this property.
See, https://github.com/confluentinc/confluent-kafka-python/issues/477 and linked issues
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
Solution | Source |
---|---|
Solution 1 | OneCricketeer |