Spring Boot集成Kafka：发送SSL关闭消息失败问题求助

我之前在集成Spring Boot和Kafka时也碰到过类似的SSL关闭消息失败问题，在不能修改Broker和上游生产者配置的情况下，确实可以通过调整客户端的配置项来解决。下面是几个经过验证的可行方案，你可以逐个尝试：

• 调整SSL连接关闭超时时间
  默认的SSL关闭超时（1000ms）可能太短，导致还没完成SSL连接关闭流程就触发了错误。你可以在application.yml的消费者配置里延长这个超时：

  spring:
    kafka:
      consumer:
        properties:
          ssl.close.timeout.ms: 5000  # 可根据实际情况调整，比如5秒或更长
  

• 指定与Broker兼容的SSL协议版本
  如果Broker使用的SSL协议版本和客户端默认值不匹配，也可能引发关闭阶段的异常。你需要确认Broker支持的SSL协议（比如TLSv1.2或TLSv1.3），然后在客户端配置中指定：

  spring:
    kafka:
      consumer:
        properties:
          ssl.protocol: TLSv1.2  # 替换为Broker实际支持的协议版本
  

• 禁用SSL会话重用
  部分场景下，SSL会话重用会导致连接关闭时出现异常，尝试禁用这个特性：

  spring:
    kafka:
      consumer:
        properties:
          ssl.enable.session.reuse: false
  

• 延长消费者优雅关闭超时
  Spring Kafka消费者默认的关闭超时（3000ms）可能不足以完成SSL连接的优雅关闭，调大这个值给足处理时间：

  spring:
    kafka:
      consumer:
        close-timeout: 10000  # 调整为10秒或更适合的时长
  

建议你先从调整SSL关闭超时和消费者关闭超时开始尝试，这两个是最常见的解决方向。如果还是不行，再依次尝试指定SSL协议和禁用会话重用。根据你的网络环境和Broker的实际情况，可能需要微调配置中的数值。

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