在 Jet 0.4 中,可以选择使用通用的group id
.
在当前 Jet 0.5 中,此group.id
值被忽略,我们如何防止 Jet 实例获取消息的重复副本?换句话说,我们希望工作负载(处理 Kafka 主题的消息)在 Jet 实例中进行负载均衡,我们如何使用 0.5 来做到这一点?
在 Jet 0.4 中,可以选择使用通用的group id
.
在当前 Jet 0.5 中,此group.id
值被忽略,我们如何防止 Jet 实例获取消息的重复副本?换句话说,我们希望工作负载(处理 Kafka 主题的消息)在 Jet 实例中进行负载均衡,我们如何使用 0.5 来做到这一点?
Jet 0.5 使用手动分区分配。即使在这种情况下,分区也会在成员之间平均分配,不会有重复。使用 Kafka 的分区分配时出现问题。