#python #apache-kafka #avro #confluent-platform #confluent-schema-registry
#python #apache-kafka #avro #confluent-платформа #confluent-schema-registry
Вопрос:
Я использую confluent Kafka и schema registry и не могу найти способ получить пользовательское имя схемы в python. Из этого блога я узнал, как это сделать на Java, но понятия не имею, что эквивалентно:
properties.setProperty("value.subject.name.strategy", TopicRecordNameStrategy.class.getName());
было бы. Добавление свойства 'key.subject.name.strategy': 'io.confluent.kafka.serializers.subject.RecordNameStrategy' в AvroProducer() не помогает. Чего я не понимаю?
Ответ №1:
Клиент Python в настоящее время не предоставляет это свойство.
Смотрите, https://github.com/confluentinc/confluent-kafka-python/issues/477 и связанные с этим проблемы
Комментарии:
1. Я полагаю, вы могли бы вручную зарегистрировать тему схемы и использовать обычный
Producerкласс