Spring Kafka Listener with topic Pattern,分配所有topic的所有partition

Spring KafkaListener with topicPattern, assign all paritions of all topics

我让@KafkaListener 使用带有正则表达式的 topicPattern,效果很好 (foo.*),但现在我想将侦听器分配给所有匹配主题的所有分区。

https://docs.spring.io/spring-kafka/docs/2.6.1/reference/html/#tip-assign-all-parts 并没有真正帮助我,因为我不知道主题名称。

使用模式时不能手动分配分区;模式仅支持组管理(Kafka 执行分配)。

如果您的应用程序只有一个实例,Kafka 将为匹配的主题分配所有分区。如果有多个实例并且您希望将它们全部分配给所有分区,则它们必须具有唯一的 group.ids.