如何在同一主题上生产和消费不同的 avro 实体?
how to produce and consume different avro entities on the same topic?
Martin Kleppmann 的这篇文章(在 Confluent 博客上)说可以将不同的事件类型放入同一个 kafka 主题中:
Should You Put Several Event Types in the Same Kafka Topic
这里是相关的代码更改请求:
New (key|value).multi.type option for Avro serialization
我的问题是,如何做到这一点?我如何定义配置生产者和消费者,以将不同的 avro 实体处理到一个共同的主题?
感谢您的帮助!
key.subject.name.strategy
value.subject.name.strategy
您可以使用 KafkaAvroSerializer
的 .configure
方法来利用这些。
我建议 looking at the unit tests 因为似乎没有关于如何使用它的深入文档部分。
Martin Kleppmann 的这篇文章(在 Confluent 博客上)说可以将不同的事件类型放入同一个 kafka 主题中: Should You Put Several Event Types in the Same Kafka Topic
这里是相关的代码更改请求: New (key|value).multi.type option for Avro serialization
我的问题是,如何做到这一点?我如何定义配置生产者和消费者,以将不同的 avro 实体处理到一个共同的主题?
感谢您的帮助!
key.subject.name.strategy
value.subject.name.strategy
您可以使用 KafkaAvroSerializer
的 .configure
方法来利用这些。
我建议 looking at the unit tests 因为似乎没有关于如何使用它的深入文档部分。