如何配置KafkaListener监听配置文件中多个逗号分隔的Topic？

1. 你当前的配置是可行的 #

你的代码和配置写法本身是有效的：在application.yaml中用逗号分隔多个topic，通过${application.kafka.topics}注入到@KafkaListener的topics属性后，Spring会自动将逗号分隔的字符串解析为topic数组，从而实现同时监听topic1和topic2。

需要注意yaml配置的缩进规范，建议统一使用2个空格缩进，修正后的配置如下：

application:
  kafka:
    topics: topic1, topic2

2. 直接在注解中指定多个Topic #

无需通过配置文件，直接给topics属性传入字符串数组即可：

@KafkaListener(topics = {"topic1", "topic2"})
public void listen(ConsumerRecord<?, ?> record, Acknowledgment ack) {
    System.out.println(record);
    ack.acknowledge(); // 手动确认模式下必须调用此方法提交偏移量
}

3. 使用正则匹配批量Topic #

如果需要监听符合特定规则的一批topic，可以使用topicPattern属性，比如匹配所有以topic开头的主题：

@KafkaListener(topicPattern = "topic.*")
public void listen(ConsumerRecord<?, ?> record, Acknowledgment ack) {
    System.out.println(record);
    ack.acknowledge();
}

关键注意事项 #

• 若消费者配置为手动确认模式（如ackMode: MANUAL），必须调用ack.acknowledge()提交偏移量，否则消息会重复消费。
• 确保消费者的group-id配置正确，同一消费组内的消费者会分摊topic的分区负载。
• 配置文件中的topic字符串若包含逗号后空格（如topic1, topic2），Spring会自动忽略空格，不影响解析，但建议保持无空格的规范写法。

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