春季卡夫卡消费者2个卡夫卡集群

本文介绍了春季卡夫卡消费者2个卡夫卡集群的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述 我有两个集群设置：站点1的集群1(3个代理)和站点2的集群2(3个代理)。 使用Spring Kafka(1.3.6)Consumer(一台机器)，并通过@KafkaListener注释监听消息。 如何为每个集群(c1和c2)实例化多个KafkaListenerContainerFactory并同时侦听这两个集群的数据。

我的侦听器应该同时使用来自两个群集的消息。

推荐答案

卡夫卡将自动连接到这两个实例，您无需再执行任何操作。

只需将这两个地址添加到bootstrap.servers配置，即使其中一个代理关闭，客户端也可以连接(但必须充分复制分区)。