消费者暂停和恢复在消费者组级别有效吗？

Question

我正在浏览Consumer 中的 kafka 暂停和恢复功能。

我想知道消费者组中的所有消费者是否都会发生这种暂停？我还在这里读到暂停状态在消费者组的 Kafka 服务器上持久化。

如果有人可以回答上述问题/为我指出正确的资源，那将会很有帮助。

Answer 1

暂停只是Consumer自身的正常行为，并不是从consumer group中移除。正如API文档所说，Pause()将暂停从分区中获取数据，此方法不会影响分区订阅。所以它不会从消费者组中删除，也不会导致组重新平衡。

如果某个消费者组中的所有消费者都发生此暂停，则将导致该组对于该主题的每个分区的 lagEndOffset 在此期间只会增加。由于Kafka的消息模型是PULL模型，所以什么时候取怎么取取决于消费者。并且同一组中的每个消费者在暂停或恢复时不会相互影响。因为它不会导致重新平衡。