我在站点 1(3 个代理)有两个集群设置 cluster-1，在站点 2(3 个代理)有 cluster-2。 使用spring kafka(1.3.6)消费者(一台机器)，通过@KafkaListener注解监听消息。 我们如何为每个集群(c1和c2)实例化多个KafkaListenerContainerFactory并同时监听两个集群的数据。
我的监听器应该同时使用来自两个集群的消息。
请您参考如下方法:
Kafka 将自动连接到两个实例，您无需执行任何其他操作。
只需将两个地址添加到 bootstrap.servers 配置中，这样即使其中一个代理关闭，客户端也可以连接(但必须充分复制分区)。
