Изменить схему названия стратегии в слитной Кафке

Question

Я использую конфлюентный реестр Kafka и схемы, и я не могу найти способ иметь собственное имя схемы в python.Из этого блога я узнал, как это сделать на Java, но понятия не имею, каким будет эквивалент:

properties.setProperty("value.subject.name.strategy", TopicRecordNameStrategy.class.getName());

.Добавление свойства 'key.subject.name.strategy': 'io.confluent.kafka.serializers.subject.RecordNameStrategy' в AvroProducer() не помогает.Чего мне не хватает?

Answer 1

Клиент Python в настоящее время не предоставляет это свойство.

См. https://github.com/confluentinc/confluent-kafka-python/issues/477 и связанные проблемы