将多个主题名称与 KafkaListener 注释一起使用

Question

下面有一个类似的问题：

---

单个 Spring 的 KafkaConsumer 侦听器可以收听多个主题吗？

所以我现在明白我可以为 KafkaListener 注释的主题参数提供一个字符串数组，但是我想知道以下内容：

1. 如何从属性文件中获取主题名称作为字符串数组？
2. 这个来自多个主题的阅读如何影响偏移量？客户端（spring kafka）会维护每个主题的偏移量吗？

Answer 1

如果您的属性是my.topics（逗号分隔的）...

@KafkaListener(id = "foo", topics = "#{'${my.topics}'.split(',')}")

是的，所有订阅的主题/分区都管理偏移量。