下面有一个类似的问题：一个spring的kafkaconsumer听众能听多个主题吗？所以我现在明白了，我可以为kafkalistener注解的topics参数提供一个字符串数组，但是我想知道以下几点：如何从属性文件中获取作为字符串数组的主题名？多个主题的阅读是如何影响偏移量的？客户机（springkafka）会保持每个主题的偏移量吗？
ldxq2e6h1#
如果你的财产 my.topics （逗号分隔）。。。
my.topics
@KafkaListener(id = "foo", topics = "#{'${my.topics}'.split(',')}")
是的，为所有订阅的主题/分区管理偏移量。
1条答案
按热度按时间ldxq2e6h1#
如果你的财产
my.topics（逗号分隔）。。。是的，为所有订阅的主题/分区管理偏移量。