pythonapache-kafkaavroconfluent-platformconfluent-schema-registry

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

  • The Python client doesn't currently expose this property.

    See, https://github.com/confluentinc/confluent-kafka-python/issues/477 and linked issues