Kafka 消费者组再均衡与偏移治理（Assignor、Offset 与会话参数）

Kafka 消费者组再均衡与偏移治理（Assignor、Offset 与会话参数）概述再均衡影响分区分配与吞吐。正确的 assignor、会话与偏移策略能降低抖动并保障一致性。关键实践与参数Assignor：使用 `cooperative-sticky` 降低再均衡抖动与重分配。会话参数：`session.timeout.ms ≈ 10s`、`heartbeat.interval.ms ≈ 3s`、`max.poll.interval.ms ≥ 300000`。偏移提交：优先批处理提交（异步）并在关闭时同步提交；保证幂等处理与失败重试。拉取与并发：控制 `max.poll.records` 与并发消费；避免长处理阻塞心跳。验证方法在扩缩与部署期间观察再均衡频次与时长；评估对吞吐的影响。故障注入下检查偏移一致性与重复消费率。监控消费者延迟（lag）与重试队列堆积。注意事项并发与背压治理；对慢消费者进行隔离或降级。在多数据中心场景中确保路由与副本策略一致。关闭前处理提交与资源清理，避免位点漂移。