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

问题描述

我有两个集群设置：站点1的集群1(3个代理)和站点2的集群2(3个代理)。使用Spring Kafka(1.3.6)Consumer(一台机器)，并通过@KafkaListener注释监听消息。如何为每个集群(c1和c2)实例化多个KafkaListenerContainerFactory并同时侦听这两个集群的数据。

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

推荐答案

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

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

这篇关于春季卡夫卡消费者2个卡夫卡集群的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！