在jet0.4中，有一个选项，可以通过使用公共 group id .在电流为0.5的情况下 group.id 值时，如何防止jet示例获取消息的重复副本？换句话说，我们希望jet示例中的工作负载（处理kafka主题的消息）是负载平衡的，我们如何使用0.5做到这一点？
group id
group.id
sg2wtvxw1#
jet0.5使用手动分区分配。分区在成员之间平均分配，即使在这种情况下，也不会有重复的分区。在使用Kafka的分区分配时出现了一个问题。
1条答案
按热度按时间sg2wtvxw1#
jet0.5使用手动分区分配。分区在成员之间平均分配，即使在这种情况下，也不会有重复的分区。在使用Kafka的分区分配时出现了一个问题。