SpringBoot-Kafka：多节点主机下Bootstrap-servers配置异常问题

单个ConsumerFactory能否连接多个多节点主机？ #

完全可以，但你给出的配置里有个小问题：BOOTSTRAP_SERVERS_CONFIG的配置值末尾多了个空格，得去掉，修正后的代码如下：

@Bean
public ConsumerFactory<String, String> consumerFactory()
{
    Map<String, Object> config = new HashMap<>();
    config.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,
               "example.dev.com:9092,example1.dev.com:9092"); // 移除末尾多余空格
    config.put(ConsumerConfig.GROUP_ID_CONFIG,
               "group_id");
    config.put(
        ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
        StringDeserializer.class);
    config.put(
        ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
        StringDeserializer.class);
    return new DefaultKafkaConsumerFactory<>(config);
}

为什么配置多个Bootstrap地址后仅能读取其中一个？ #

你说的“仅能读取其中一个”其实是对Kafka消费者逻辑的误解：

• Kafka的bootstrap-servers只是消费者用来获取集群元数据的入口，只要能连上其中一个可用节点，消费者就会自动拉取整个集群的所有节点信息、主题分区分布等数据。
• 你配置的两个域名example.dev.com:9092和example1.dev.com:9092实际指向的是同一个Kafka集群的节点（都是node:9092、node2:9092、node3:9092），所以消费者不管用哪个入口，最终都会和集群内所有节点建立连接，消费所有分区的消息，不会只盯着某个入口节点消费。
• 你感知到的“仅读取一个”大概率是错觉——消费者会根据分区分配策略，从集群各个节点的分区获取消息，不会固定绑定某个Bootstrap地址对应的节点。

补充说明 #

如果你的两个域名实际指向不同的Kafka集群，那单个ConsumerFactory没法同时消费两个集群的消息——Kafka消费者本身是绑定单个集群的，这种情况得给每个集群单独创建ConsumerFactory和对应的消费者实例。

内容的提问来源于stack exchange，提问作者Rocky4Ever