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