Spring Cloud Stream Kafka消费者自动发送LeaveGroup请求停止消费排查

1. 绑定重试间隔配置为0：你配置的bindingRetryInterval: ${BINDING_RETRY_INTERVAL:0}会导致当Kafka客户端与broker出现短暂连接异常、coordinator抖动导致消费组重平衡失败时，Spring Cloud Stream判定绑定不可用后不会重试重建，直接销毁消费者容器，触发主动退组、取消订阅的逻辑。
2. 未捕获异常触发容器销毁：消费逻辑中未捕获的RuntimeException在maxAttempts配置的重试次数耗尽后仍未处理，会向上抛到Listener容器层，默认策略下会直接停止消费者容器。
3. 反序列化配置冲突：你配置了useNativeDecoding: false （使用Spring自带消息转换器解析消息），同时又在consumerProperties中配置了原生Kafka Avro反序列化器，两者逻辑冲突时会抛出解析异常，反复触发后会导致容器停止。
4. 网络波动导致心跳失败：未配置合理的会话超时、心跳间隔参数，网络短暂抖动时消费者连续心跳失败被broker踢出借组，超过失败阈值后触发容器销毁。

• 调整绑定重试间隔为大于0的值，建议设为30000（30秒），绑定失败后自动重试重建消费者：

spring:
  cloud:
    stream:
      bindingRetryInterval: ${BINDING_RETRY_INTERVAL:30000}

• 开启消费者容器重启能力，异常销毁后自动重启：

spring:
  cloud:
    stream:
      default:
        consumer:
          restartable: true

• 统一反序列化配置，开启原生解码适配你配置的KafkaAvroDeserializer：

spring:
  cloud:
    stream:
      default:
        consumer:
          useNativeDecoding: true

• 开启DLQ死信队列，将消费失败的消息投递到死信队列避免异常反复抛出：

spring:
  cloud:
    stream:
      kafka:
        bindings:
          outbox:
            consumer:
              enableDlq: ${ENABLE_DLQ:true}
              dlqName: my_outbox_topic_dlq

• 调整Kafka消费者心跳、会话超时参数，避免网络波动导致误判消费者离线：

spring:
  cloud:
    stream:
      kafka:
        binder:
          consumerProperties:
            session.timeout.ms: 30000
            heartbeat.interval.ms: 3000
            max.poll.interval.ms: 300000

内容的提问来源于stack exchange，提问作者vukojevicf