配置消费者重平衡监听器需实现consumerrebalancelistener接口并在subscribe时注册，核心用于分区变更时状态清理与兜底提交，而非主offset提交逻辑。
配置消费者的重平衡监听器，核心是实现 ConsumerRebalanceListener 接口，并在订阅主题时注册。它不用于提交 offset，而是配合手动提交策略，在分区分配变化时做状态清理或兜底提交。
注册监听器并实现两个关键方法
监听器需实现 onPartitionsAssigned 和 onPartitionsRevoked 两个方法：
-
onPartitionsRevoked(Collection
partitions) ：分区被撤回前触发，适合做“兜底提交”——提交已处理但尚未 commit 的 offset；可调用commitSync()，但必须捕获CommitFailedException，不能阻塞 rebalance 流程 -
onPartitionsAssigned(Collection
partitions) ：新分区分配后触发，适合初始化本地状态（如清空缓存、重置指标），不要在此处 seek 或 commit；若需从特定 offset 恢复（如基于外部 DB 存储的位移），可在该方法中调用seek(topicPartition, offset)
搭配手动提交策略使用
监听器本身不是 offset 提交主逻辑，而是安全边界。推荐组合方式：
- 主循环中每处理完一批消息（如 500 条）或间隔固定时间（如 1 秒），调用
consumer.commitSync() -
onPartitionsRevoked作为最后一道保障：即使主循环因异常中断，只要发生 rebalance，仍有机会提交已处理数据 - 关闭自动提交：
enable.auto.commit=false，避免与手动逻辑冲突
注意协调参数避免频繁触发
监听器生效的前提是 rebalance 实际发生。若因配置不当导致频繁 rebalance，监听器会被反复调用，反而增加风险：
- 确保
session.timeout.ms（如 10000）足够容纳业务处理时间，且heartbeat.interval.ms（如 3000） ≤ session.timeout.ms / 3 - 控制单次拉取量：
max.poll.records=500，防止单次 poll 后处理超时，触发max.poll.interval.ms超时而被踢出组 - 避免在
onPartitionsRevoked中执行耗时操作（如远程调用、复杂计算），否则会拖慢 rebalance 过程
代码注册示例
订阅时传入监听器实例即可：
consumer.subscribe(Arrays.asList("topic-a"), new CustomRebalanceListener());其中 CustomRebalanceListener 是你实现的 ConsumerRebalanceListener 子类。无需额外启动或注册，Kafka 客户端会在每次 rebalance 前后自动回调对应方法。
