'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