【问题标题】:Change schema name strategy in confluent Kafka在融合的 Kafka 中更改模式名称策略
【发布时间】: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


    【解决方案1】:

    Python 客户端当前不公开此属性。

    请参阅https://github.com/confluentinc/confluent-kafka-python/issues/477 和相关问题

    【讨论】:

    • 我想您可以手动注册模式主题并使用常规 Producer
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2018-12-19
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2020-07-27
    相关资源
    最近更新 更多