我是 Kafka 的新手并且阅读了一些教程。我无法理解消费者和分区之间的关系。
请解决我的以下问题。
-
根据文档，只有一个消费者可以使用组中的消息。为什么我们需要在同一组中创建更多的消费者？有什么好处？
-
是否将消费者分配给 ZK 的个别分区？ ，如果是，如果生产者向不同的分区发送消息，那么其他分区的消费者将如何消费该消息？
-
我有一个主题，有 3 个分区。我发布消息，它转到 P0。我有 5 个消费者(不同的消费群体)。所有消费者都会从 P0 读取消息吗？如果我增加许多消费者，是否所有消息都来自同一个 P0？如果所有消费者都从相同的 PO 读取，那么性能将如何高？
-
重新平衡如何运作？当您增加同一组中的消费者群体或消费者时它会起作用吗？
请澄清我的问题并举一些例子。
1 回答
是的，只有一旦消费者组中的消费者可以消费来自一个分区的消息，同一组中的其余消费者将被分配给剩余分区以进行并行处理。优点是并行处理。
是的分区将由 ZK 分配给消费者。根据分区计数和使用者计数，将完成分配。例如：主题(测试)有 3 个分区(P1，P2 和 P3)。我们有一个消费者(C1)。 C1 将从所有分区读取消息。如果在同一组中再添加一个使用者(c2)。 ZK 将 P1，p2 分配给 C1，P3 进入 C2。如果再添加一个消费者(C3)而不是 P1=C1，P2=C2 和 P3=C3。对于该主题，消费者的数量不应大于否。
以上几点将回答这一点。
在同一个使用者组中添加使用者时，重新平衡将起作用。