| 触发 | 成员加入/退出、订阅变更、分区数变化 |
|---|---|
| 影响 | 分区重新分配，短暂停顿或部分分区暂停 |
| 缓解 | 合作式均衡、静态成员、合理调大会话与处理超时 |
降低影响的客户端配置
降低影响的客户端配置
partition.assignment.strategy=org.apache.kafka.clients.consumer.CooperativeStickyAssignor
group.instance.id=consumer-1 # 静态成员，短暂重启不触发再均衡
session.timeout.ms=45000
max.poll.interval.ms=300000处理单批数据耗时超过 max.poll.interval.ms 会被踢出组，引发“处理慢→被踢→再均衡→更慢”的循环。