【问题标题】:Spring KafkaListener with topicPattern, assign all paritions of all topicsSpring KafkaListener with topicPattern,分配所有主题的所有分区
【发布时间】:2020-10-07 15:08:22
【问题描述】:

我有 @KafkaListener 使用 topicPattern 和一个正常工作的正则表达式 (foo.*),但现在我想将侦听器分配给所有匹配主题的所有分区。

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

【问题讨论】:

    标签: java spring spring-kafka


    【解决方案1】:

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

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

    【讨论】:

      猜你喜欢
      • 2022-07-28
      • 2022-08-16
      • 1970-01-01
      • 2020-06-17
      • 2016-12-30
      • 2016-04-19
      • 2021-10-05
      • 1970-01-01
      • 2016-10-15
      相关资源
      最近更新 更多