spring-kafka - 2 kafka集群的spring kafka消费者

Question

我有两个集群设置 cluster-1 在站点 1(3 brokers) 和 cluster-2 在站点 2(3 brokers) 。使用 spring kafka(1.3.6) 消费者（一台机器）并通过@KafkaListener 注解监听消息。我们如何为每个集群（c1 和 c2）实例化多个 KafkaListenerContainerFactory 并同时监听来自两个集群的数据。

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

标签： spring-kafka

Answer 1

Kafka 将自动连接到这两个实例，您无需再做任何事情。

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