在我们的一个基于spring-boot的服务中,我们打算同时连接到两个不同的kafka集群。这些集群每个都有自己的一组引导服务器,主题配置等。它们之间没有任何联系,就像this question中的情况一样。
我将在不同的主题名称上从每个集群读取不同类型的消息。可能有也可能没有多个生产者从这个服务连接到两个集群,但我们肯定每个集群至少有一个消费者。
我想知道如何在application.yml中定义属性来迎合这种设置,这样我就可以使用2个不同的KafkaProperties对象来创建4个容器工厂(2个消费者,2个生产者)。我相信剩下的应该非常简单,因为我需要使用相关的工厂来根据业务需求创建一个特定的容器/侦听器/kafkaTemplate。
发布于 2020-07-27 22:24:13
您不能这样做;您需要禁用Boot的自动配置,并自行为每个集群配置基础架构bean。
Boot的自动配置只支持一个集群。
https://stackoverflow.com/questions/63110194
复制相似问题