为什么在单个组中分配新分区之前不正确撤销所有消费者答案

【问题标题】：Why not all consumers are properly revoked before assigning new partitions within singe group为什么在单个组中分配新分区之前不正确撤销所有消费者
【发布时间】：2021-12-06 05:33:32
【问题描述】：

考虑有 4 个消费者 (A,B,C,D) 。 C 通过调用 close() 关闭。理想情况下，分配给 A、B 和 D 的分区应该在分配任何新分区之前被撤销，但是 A 被撤销并获得新分区，然后 B 被撤销。为什么会观察到这种行为？如何解决。

【问题讨论】：

标签： java apache-kafka kafka-consumer-api

【解决方案1】：

在 Kafka 2.4 中添加了一个新的增量重新平衡协议，该协议不会在重新平衡期间撤销所有分区：https://www.confluent.io/blog/cooperative-rebalancing-in-kafka-streams-consumer-ksqldb/

【讨论】：