ThinkChat🤖让你学习和工作更高效,注册即送10W Token,即刻开启你的AI之旅 广告
# 消费者组重平衡 一个问题:消费者组重平衡能避免吗? * Rebalance * 一个 Consumer Group 下所有的 Consumer Instance 就如何消费订阅 Topic 的所有分区达成共识的过程 * 整个过程中,由于所有实例不能消费,因此对 Consumer 的 TPS 影响很大 * 协调者 aka. Coordinator * 专为 Consumer Group 服务 * 负责 Group 执行 Rebalance 以及提供位移管理、组成员管理 * Consumer 端提交 offset,实际上是向 Coordinator 所在的 Broker 提交 offset * 当 Consumer 启动时,也是向 Coordinator 所在的 Broker 发送各种请求,由 Coordinator 负责执行消费者组的注册、成员管理记录等元数据管理操作 * 所有的 Broker 都有自己的 Coordinator 组件 *