spring Kafka多个消费者示例不接收消息

xdnvmnnf  于 2022-11-21  发布在  Spring
关注(0)|答案(1)|浏览(132)

我有一个应用程序,我想在多个示例中打开,我需要每个示例来接收消息。实际上,每个示例只有在示例具有不同的组ID时才能接收消息。我放置了比实际示例更多的分区,但它不工作。应用程序同时作为消费者/生产者工作。代码:
第一个
你知道为什么会发生这种情况,因为我认为如果我将有更多的分区每组比示例,这将工作?

gv8xihay

gv8xihay1#

Kafka就是这样被设计出来的;对于要获取所有记录的多个示例,它们必须位于不同的组中。
当它们在同一组中时,分区分布在活动示例中。每次有新成员到达或离开时,分区都将重新平衡

相关问题