apache-kafka - 如果消费者组成员宕机，Kafka 消息会发生什么？

Question

假设我们有一个名为 Topic 的主题还有一个消费群CG与三个消费者。组偏移等于 0。

消费者开始阅读消息。

读取顺序:

消费者 1 读取消息 1。

消费者 2 读取消息 2。

消费者 3 读取消息 3。

消费者 2 提交消息 2。

消费者 3 提交消息 3。

消费者 1 处理消息 1 失败并关闭。

问题是:消息 1 会发生什么？

或者也许我错误地理解了消费者如何阅读消息，因为我是 Kafka 的新手。

版本:Apache Kafka 2.4.0

Answer 1

每个消费者都会有分配给他们的分区。
假设我们有 6 个分区:

消费者 1:分区 1 和 2
消费者 2:分区 3 和 4
消费者 3:分区 5 和 6

当消费者 1 宕机时，消费者组将重新平衡并将空闲分区分配给其他消费者，从而为我们提供以下设置:

消费者2:分区 1 & 3 & 4
消费者3:分区 2 & 5 & 6

其他消费者将从该分区上最后提交的偏移量开始。