Spring Kafka无消息触发重平衡致GCP负载重启问题求助

基于Spring Boot+Spring Kafka搭建POC，部署在GCP负载中，消费Confluent Cloud中仅含1个分区、保留期1天的主题。配置了精确一次处理（exactly-once），消费者端设置spring.kafka.consumer.isolation-level=read_committed，未修改Kafka消费者心跳、会话超时等默认配置。

启动后消费者初始分配至partition-0，但当主题无消息达30分钟至1小时时，触发消费者重平衡，导致GCP负载多次重启。日志显示消费者主动退组并取消订阅所有主题。

监听器代码 #

@KafkaListener(topic = "${topic.name}")
public void listen(ConsumerRecord<String, TestData> record, Acknowledgment ack){
   ack.acknowledge();
   list.add(record.value());
}

负载日志 #

2025-04-23T15:32:24.270-04-00 INFO 1 --- [kafka-poc] [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : GROUP-ID-DEV: partitions assigned: [dev-topic-0]
2025-04-23T15:34:31.270-04-00 INFO 1 --- [kafka-poc] [ntainer#0-0-C-1] k.c.c.i.ConsumerRebalanceListenerInvoker : [Consumer clientId=GROUP-ID-DEV-1, groupId=GROUP-ID] Revoke previously assigned partitions dev-topic-0
2025-04-23T15:34:32.270-04-00 INFO 1 --- [kafka-poc] [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : dev-topic: partitions revoked: [dev-topic-0]
2025-04-23T15:34:32.270-04-00 INFO 1 --- [kafka-poc] [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : Member consumer sending LeaveGroup request to coordinator <confluent cloud broker url> due to the consumer unsubscribed from all topics
2025-04-23T15:34:32.270-04-00 INFO 1 --- [kafka-poc] [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : Resetting generation and member id due to: consumer pro-actively leaving the group

• 检查GCP负载健康检查配置：确认负载均衡的健康检查间隔、超时时间，避免无消息阶段因服务长时间无请求被误判为不健康触发重启。确保健康检查周期不与Kafka消费者会话超时（默认30秒）、心跳间隔（默认3秒）冲突。
• 调整Kafka消费者空闲相关配置：
  • 调大spring.kafka.consumer.max.poll.interval.ms（默认5分钟），比如设为3600000（1小时），避免无消息时因超过轮询间隔被判定为失效。
  • 设置spring.kafka.listener.idle-event-interval配置空闲事件间隔，便于跟踪无消息阶段的容器状态。
• 排查主动退组触发逻辑：检查是否存在自定义RebalanceListener或Spring Kafka自动配置导致无消息时取消订阅。显式指定spring.kafka.listener.ack-mode=MANUAL_IMMEDIATE，确保手动提交逻辑正常，无额外退组触发代码。
• 验证Confluent Cloud主题与连接状态：确认主题的min.insync.replicas、cleanup.policy等配置无异常，排查消费者与Confluent Cloud Broker的网络连接稳定性，是否存在网络超时导致主动退组。
• 开启调试日志跟踪状态：将org.springframework.kafka和org.apache.kafka包的日志级别设为DEBUG，查看无消息阶段消费者的状态变化、是否触发空闲回调或定时清理动作。
• 隔离精确一次配置影响：临时关闭精确一次处理配置，测试是否仍出现退组现象，排除事务或read_committed隔离级别导致的异常逻辑。

内容的提问来源于stack exchange，提问作者Rico Sancho Abarro