Kafka离线时Spring应用无法启动，如何实现无Kafka也能正常启动？

要让应用在Kafka离线时仍能启动并仅输出警告，只需调整配置如下：

修改后的完整配置 #

spring:
  application:
    name: connector
  cloud:
    stream:
      kafka:
        binder:
          replicationFactor: 1
          auto-create-topics: true
          brokers: localhost:9092
          # 连接失败重试1次后停止，避免持续阻塞启动
          failure-threshold: 1
          # 重试间隔2秒
          retry-interval: 2000
          # 生产者无需等待Broker确认，消除启动时的阻塞点
          required-acks: 0
      bindings:
        binding-in:
          destination: queue-0
          content-type: application/json
          group: connector
          auto-startup: true
          consumer:
            # 消费端尝试连接失败1次后停止，仅输出警告
            max-attempts: 1
            back-off-initial-interval: 1000
        binding-out:
          destination: queue-1
          content-type: application/json
          group: connector
          producer:
            # 异步发送消息，不等待Broker响应
            sync: false

关键配置说明 #

• failure-threshold: 1：限制Kafka binder的连接重试次数，超过次数后停止尝试，不会一直阻塞应用启动流程
• required-acks: 0：生产者发送消息时不等待Broker的确认回执，避免因Kafka离线导致启动阶段阻塞
• binding-in.consumer.max-attempts: 1：消费端仅尝试连接1次，失败后输出警告日志，不再持续重试
• binding-out.producer.sync: false：生产者以异步方式发送消息，不阻塞主线程，保证应用能顺利启动

配置完成后，当Kafka离线时，应用会正常启动，日志中会输出Kafka连接失败的警告信息，待Kafka恢复后，消费和生产功能会自动恢复。

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