Spring Kafka中@RetryableTopic自动创建主题时的Bootstrap Server连接疑问

这个行为是预期的，但源于配置疏漏，具体原因和解决方式如下：

原因解析 #

当autoCreateTopics = "true"时，Spring Kafka的@RetryableTopic机制会在应用启动阶段，自动尝试创建重试主题、死信主题等关联资源。这个创建操作依赖KafkaAdmin组件完成——如果你没有显式定义自定义的KafkaAdmin Bean，Spring会自动生成一个**使用默认配置（bootstrap.servers=127.0.0.1:9092）**的实例。

而你虽然自定义了consumerFactory和producerFactory并配置了正确的MSK地址，但这两个Bean和KafkaAdmin是独立的。启动初期KafkaAdmin先加载，用默认地址连接失败；之后你的自定义工厂Bean完成初始化，才会使用正确的MSK地址建立连接，所以会出现先失败后成功的现象。

当autoCreateTopics = "false"时，@RetryableTopic不会触发主题创建逻辑，也就不会用到默认的KafkaAdmin，直接使用你自定义工厂的配置连接MSK，所以不会有初期连接失败的问题。

解决办法 #

你需要让KafkaAdmin使用和自定义工厂一致的bootstrap配置，有两种方式：

• 显式定义KafkaAdmin Bean：

  @Bean
  public KafkaAdmin kafkaAdmin() {
      Map<String, Object> configs = new HashMap<>();
      configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "你的MSK bootstrap地址");
      // 按需添加其他安全认证等配置
      return new KafkaAdmin(configs);
  }
  

• 通过配置文件统一指定：
  在application.properties或application.yml中设置全局Kafka配置，让自动生成的KafkaAdmin直接复用：

  spring.kafka.bootstrap-servers=你的MSK bootstrap地址
  

这样无论autoCreateTopics设为true还是false，所有Kafka相关组件都会使用正确的bootstrap地址，不会出现初期连接失败的问题。

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