【发布时间】:2019-08-11 11:20:36
【问题描述】:
我正在使用融合的 Kafka 和模式注册表,但我无法找到在 python 中使用自定义模式名称的方法。从这个blog我知道了如何用Java做,但不知道相当于什么:
properties.setProperty("value.subject.name.strategy", TopicRecordNameStrategy.class.getName());
会的。在AvroProducer() 中添加属性'key.subject.name.strategy': 'io.confluent.kafka.serializers.subject.RecordNameStrategy' 没有帮助。我错过了什么?
【问题讨论】:
标签: python apache-kafka avro confluent-platform confluent-schema-registry