0

我打算使用Kafkajs https://kafka.js.org/并在 NodeJs 服务器中实现它。我想知道如果我有 2 个（或更多）服务器实例正在运行，每个实例都有一个配置有相同组 ID 和主题的消费者，那么预期的行为是什么？

这是否意味着他们可能会阅读相同的消息？我应该为每个服务器实例指定一个唯一的消费者组吗？

我读到这个 ​​-多个消费者从同一个主题消费，但不确定它是否适用Kafkajs

4

1 回答 1

1

单个消费者组不可能有多个消费者从任何 Kafka 库中的重叠分区中读取数据。如果您的主题只有一个分区，则只有一个应用程序实例将使用它，如果该实例死亡，该组将重新平衡，另一个实例将接管（可能读取一些相同的数据，由于性质至少一次交付，但与另一个实例不同时）

于 2022-02-10T15:26:17.267 回答