卡夫卡总是一个消费者在一组中消费主题消息

Question

我有两个具有相同组 ID 的消费者服务器订阅了相同的主题。 kafka 服务器只运行一个分区。 据我所知，消息应该在这两个消费者服务器中随机消费。 但现在似乎总是同一个消费者服务器 A 消费消息，另一台不消费消息。如果我停止消费者服务器 A，另一台将正常工作。 我期望他们可以随机消费消息。

Answer 1

为了能够并行使用两个消费者实例，您需要在主题中至少有两个分区。消费者将绑定到主题的一个或多个分区，具有相同 groupId 的其他消费者将不会声明已经绑定消费者的分区。如果消费者失败/崩溃，分区将被释放，然后被另一个消费者实例拾取。