Jet Kafka负载均衡

Question

在Jet0.4中，有一个选项可以通过使用通用的group id来负载平衡从Kafka主题读取的Jet实例。

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

Answer 1

Jet 0.5使用手动分区分配。分区在成员之间平均分割，即使在这种情况下，也不会有重复。当它使用Kafka的分区分配时，有一个issue。