Spring Kafka消费者在Broker滚动重启后僵死，如何实现自动恢复？

从日志核心信息Authentication/Authorization Exception and no authExceptionRetryInterval set可以判断：未配置认证异常重试间隔导致容器直接停止，进而消费者主动退出消费组，最终出现僵死状态。结合你基于spring-starter-parent 2.6.6的Spring Kafka环境，可通过以下配置解决：

1. 配置认证异常自动重试 #

Spring Kafka默认遇到SASL认证异常时会直接停止容器，设置authExceptionRetryInterval可让容器周期性重试连接，而非直接终止：

YAML配置方式 #

spring:
  kafka:
    listener:
      auth-exception-retry-interval: 5000 # 每5秒重试一次，可根据实际场景调整

Java代码配置方式 #

如果使用自定义容器工厂，在ConcurrentKafkaListenerContainerFactory中设置：

@Bean
public ConcurrentKafkaListenerContainerFactory<?, ?> kafkaListenerContainerFactory(ConsumerFactory<Object, Object> consumerFactory) {
    ConcurrentKafkaListenerContainerFactory<Object, Object> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(consumerFactory);
    // 设置认证异常重试间隔，单位为毫秒
    factory.getContainerProperties().setAuthExceptionRetryInterval(5000);
    return factory;
}

2. 强化消费者连接重试参数 #

显式配置连接和重试参数，提升Broker恢复后的自动重连能力：

spring:
  kafka:
    consumer:
      retries: 10 # 消息拉取重试次数
      retry-backoff-ms: 1000 # 重试间隔毫秒数
    properties:
      reconnect.backoff.ms: 1000 # 初始重连间隔
      reconnect.backoff.max.ms: 30000 # 最大重连间隔，避免无限等待

3. 确保Broker认证配置一致性 #

滚动重启Broker时，必须保证所有节点的SASL认证配置（如JAAS文件、用户名密码、认证机制）完全一致，避免部分节点认证信息不一致导致客户端连接失败。重启后建议用kafka-console-consumer.sh分别测试连接每个Broker节点，验证认证服务正常。

设置以上配置后，消费者在Broker滚动重启导致的认证异常时，会自动周期性重试连接，无需手动重启即可恢复消费。

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