在融合的 Kafka 中更改模式名称策略
Change schema name strategy in confluent Kafka
我正在使用融合的 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 客户端目前不公开此 属性。
参见 https://github.com/confluentinc/confluent-kafka-python/issues/477 和相关问题
我正在使用融合的 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 客户端目前不公开此 属性。
参见 https://github.com/confluentinc/confluent-kafka-python/issues/477 和相关问题