如何在同一主题上生产和消费不同的 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 实体处理到一个共同的主题?

感谢您的帮助!

added properties

key.subject.name.strategy
value.subject.name.strategy

您可以使用 KafkaAvroSerializer.configure 方法来利用这些。

我建议 looking at the unit tests 因为似乎没有关于如何使用它的深入文档部分。