如何在同一主题上生产和消费不同的avro实体？
我的问题是，如何做到这一点？我如何定义和配置一个生产者和消费者，可以处理不同的avro实体到一个共同的主题？
谢谢你的帮助！
共有1个答案
添加的属性包括
key.subject.name.strategy
value.subject.name.strategy
您可以使用KafKaavroSerializer的.configure方法来利用这些。
我建议查看单元测试，因为似乎没有关于如何使用它的深入文档部分。
-
我试图改变生产者和消费者配置的顺序，但没有帮助。 编辑：我已经添加了完整的application.yml。当我第一次引导服务时，这个主题在Kafka中是不存在的。 它感觉在生产者和消费者配置之间有冲突，我认为它说有3个分区的原因是消费者中的并发性是3，所以它首先创建有3个分区的主题，然后当它移动到生产者配置时，它不调整分区计数。
-
我有一个spring boot项目，我是spring-kafka来连接底层的kafka事件枢纽。 我不得不在同一节消费者课上听2个不同的话题。我有两种方法可以这样做。 一个是要有两个这样的Kafka听众： 另一种方法是在同一个kafkaListener中有两个主题，如下所示 ===================edit===============application.yml中的Kafka属性
-
我最近开始使用消息队列（使用ActiveMQ)，并进行了试验。 null 谢谢你的建议，
-
我有一个usecase，其中传入的数据有一个标识不同类型数据的键。有一个单一的输入Kafka主题，所有类型的数据都抛向它。beam管道从输入的kafka主题中读取所有消息，并必须根据关键字路由到不同的kafka主题。 如何使用apache Beam的kafkaIO生产者？
-
我有两个线程的问题，似乎没有正确同步。我基本上有一个布尔值名为“已占用”。当没有线程启动时，它被设置为false。但是当一个线程启动时，线程集被占用是真的，我有一个类，它有线程（run），它们调用下面的函数。 这是一个模拟银行的示例，它接收一个金额（初始余额），然后随机执行取款和存款。我的教授提到了一些关于从取款线程到存款线程的信号？这是怎么回事？在提取线程中，它应该运行到余额为2低，并等待存款线
-
我怎样才能暗示SpringKafka把每一个话题传播给一个不同的消费者呢？ 干杯