见如下示例
主要见 @KafkaListener 中 topics 属性的配置
其中 ${xxxx.topic1} 为从springBoot 配置文件中读取的属性值文章来源：https://www.toymoban.com/news/detail-834317.html
@KafkaListener(topics = {"${xxxx.topic1}", "${xxxx.topic2}"}, groupId = "${xxxx.groupId}",
containerFactory = "xxxKafkaFactory")
public void xxxXXX(ConsumerRecord<String, String> record, Acknowledgment ack,
@Header(KafkaHeaders.RECEIVED_TOPIC) String topic) {
// ..........
}
理由
由于该注解 topic 为字符串数组的类型，所以可以如上加大括号来完成指定
文章来源地址https://www.toymoban.com/news/detail-834317.html
到了这里，关于@KafkaListener 注解配置多个 topic的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
