Spring Cloud Stream应用mvn打包时无法访问Kafka服务报错如何解决

错误原因 #

执行mvn clean package时默认会触发Spring Boot的测试执行流程，测试上下文加载过程中会初始化Spring Cloud Stream绑定逻辑，主动连接配置的Kafka服务端做Topic校验、绑定创建等操作，由于打包环境无法解析OpenShift内网域名kafka-svc.msgbus因此触发报错。

解决方案 #

可根据实际场景选择以下任意一种方案解决：

• 方案1：临时跳过测试直接打包
  不需要在打包阶段执行单元测试时，直接给Maven命令添加跳过测试参数即可，是最快捷的处理方式：

  # 跳过测试执行，保留测试编译
  mvn clean package -DskipTests
  # 跳过测试编译和执行
  mvn clean package -Dmaven.test.skip=true
  

• 方案2：测试环境覆盖Kafka配置
  需要保留测试执行时，在src/test/resources目录下新建application.properties，覆盖Kafka相关配置，避免访问内网地址：

  # 替换为本地可访问的Kafka地址
  spring.cloud.stream.kafka.binder.brokers=localhost:9092
  # 若无本地Kafka，可直接排除Kafka Streams binder自动配置，避免初始化连接
  spring.autoconfigure.exclude=org.springframework.cloud.stream.binder.kafka.streams.autoconfigure.KafkaStreamsBinderAutoConfiguration
  

• 方案3：关闭Kafka自动连接校验特性
  在主配置文件中添加以下配置，关闭初始化阶段的主动连接校验逻辑，仅在实际收发消息时才会建立Kafka连接：

  # 关闭自动创建Topic特性，避免初始化AdminClient触发连接
  spring.cloud.stream.kafka.binder.auto-create-topics=false
  # 关闭Kafka健康检查，避免监控端点触发连接
  management.health.kafka.enabled=false
  

• 方案4：多环境配置拆分（推荐长期使用）
  把不同环境的配置拆分管理，将OpenShift内网Kafka配置仅放到对应环境的配置文件中，本地打包默认加载开发环境配置：

  1. 新建application-openshift.properties，将内网Kafka配置移动到该文件
  2. 应用部署到OpenShift时，添加启动参数--spring.profiles.active=openshift加载对应配置
  3. 本地打包默认不激活该profile，不会加载内网Kafka地址

如果需要执行完整的Kafka相关集成测试，可在测试依赖中引入spring-kafka-test，使用官方提供的嵌入式Kafka模拟服务，无需连接远程实例。

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