我有一个应用程序,我想在多个示例中打开,我需要每个示例来接收消息。实际上,每个示例只有在示例具有不同的组ID时才能接收消息。我放置了比实际示例更多的分区,但它不工作。应用程序同时作为消费者/生产者工作。代码:第一个你知道为什么会发生这种情况,因为我认为如果我将有更多的分区每组比示例,这将工作?
gv8xihay1#
Kafka就是这样被设计出来的;对于要获取所有记录的多个示例,它们必须位于不同的组中。当它们在同一组中时,分区分布在活动示例中。每次有新成员到达或离开时,分区都将重新平衡
1条答案
按热度按时间gv8xihay1#
Kafka就是这样被设计出来的;对于要获取所有记录的多个示例,它们必须位于不同的组中。
当它们在同一组中时,分区分布在活动示例中。每次有新成员到达或离开时,分区都将重新平衡