0

在 Jet 0.4 中,可以选择使用通用的group id.

在当前 Jet 0.5 中,此group.id值被忽略,我们如何防止 Jet 实例获取消息的重复副本?换句话说,我们希望工作负载(处理 Kafka 主题的消息)在 Jet 实例中进行负载均衡,我们如何使用 0.5 来做到这一点?

4

1 回答 1

1

Jet 0.5 使用手动分区分配。即使在这种情况下,分区也会在成员之间平均分配,不会有重复。使用 Kafka 的分区分配时出现问题。

于 2018-04-03T19:32:24.603 回答