Kafka消费者再平衡与分区分配策略概览再平衡在成员变化或订阅变化时触发;选择合适的分配策略与参数可减少停顿与抖动。静态成员与协作再平衡进一步降低影响面。技术参数(已验证)分配策略:`range`/`roundrobin`/`sticky` 与 `cooperative-sticky`;后者在再平衡中渐进转移。超时与心跳:`session.timeout.ms`/`heartbeat.interval.ms`/`max.poll.interval.ms`;控制活跃与长处理。提交偏移:手动提交与批量;确保在再平衡前提交以避免重复处理。静态成员:`group.instance.id` 保持稳定分配;减少频繁再平衡。监听与钩子:处理 `onPartitionsRevoked`/`onPartitionsAssigned`;在撤销时暂停并提交,在分配时恢复。实战清单根据主题与消费者数量选择 `sticky` 或 `cooperative-sticky`;启用静态成员。监控再平衡事件与耗时;优化处理时间与批量提交策略。在故障与扩缩容场景演练再平衡行为;保持幂等与顺序。

发表评论 取消回复