企业🤖AI Agent构建引擎,智能编排和调试,一键部署,支持私有化部署方案 广告
# 消费者组重平衡 一个问题:消费者组重平衡能避免吗? * 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 组件 *