在我们的一个基于spring引导的服务中,我们打算同时连接到两个不同的kafka集群。这些集群都有自己的一组引导服务器、主题配置等,它们之间没有任何关联,就像这个问题中的情况一样。
我将有不同类型的消息从不同的主题名称上的每个集群读取。可能有多个生产者从这个服务连接到两个集群,也可能没有,但是我们肯定每个集群至少有一个消费者。
我想知道如何在application.yml中定义属性以适应这种设置,这样我就可以使用2个不同的 KafkaProperties
对象创建4个容器工厂(2个消费者,2个生产者)。其余的,我相信,应该是相当直接的,因为我需要使用相关的工厂根据业务需求创建一个特定的容器/侦听器/kafkatemplate。
1条答案
按热度按时间8gsdolmq1#
你不能;您需要禁用boot的自动配置,并自己为每个集群配置基础结构bean。
boot的自动配置只支持一个集群。