我计划使用Kafkajs https://kafka.js.org/并在NodeJs服务器中实现它。我想知道,如果我有2个(或更多)服务器运行实例,其中每个实例的使用者都配置了相同的组id和主题,那么预期的行为是什么?
这是否意味着他们可能会读到同样的信息?我应该为每个服务器实例指定一个唯一的使用者组吗?
我读过这个- Multiple consumers consuming from same topic,但不确定它是否适用于Kafkajs
发布于 2022-02-10 15:26:17
一个消费者组不可能让多个消费者从任何Kafka库中的重叠分区读取数据。如果您的主题只有一个分区,则应用程序的一个实例将使用它,如果该实例死亡,则组将重新平衡,而另一个实例将接管(由于至少一次传递的性质,可能会读取一些相同的数据,但并不与另一个实例同时进行)。
https://stackoverflow.com/questions/71067020
复制相似问题