martin kleppmann(在confluent博客上)有一篇文章说,在同一个Kafka主题中有不同的事件类型是可能的:你应该在同一个Kafka主题中放几个事件类型吗
下面是相关的代码更改请求:new(key | value).multi.type选项用于avro序列化
我的问题是,这怎么办?如何定义和配置可以将不同的avro实体处理为一个公共主题的生产者和消费者?
谢谢你的帮助!
martin kleppmann(在confluent博客上)有一篇文章说,在同一个Kafka主题中有不同的事件类型是可能的:你应该在同一个Kafka主题中放几个事件类型吗
下面是相关的代码更改请求:new(key | value).multi.type选项用于avro序列化
我的问题是,这怎么办?如何定义和配置可以将不同的avro实体处理为一个公共主题的生产者和消费者?
谢谢你的帮助!
1条答案
按热度按时间olmpazwi1#
添加的属性是
你会用
.configure
方法KafkaAvroSerializer
利用这些。我建议查看单元测试,因为似乎没有关于如何使用它的深入文档部分。