Spring Boot 应用运行 Kafka Testcontainer 出现连接问题如何解决

问题核心原因 #

1. 为bootstrap.servers配置添加了多余的BROKER://协议前缀，Kafka原生客户端无法识别该前缀，会直接解析失败
2. 使用了容器内部的网络别名作为连接地址，运行在宿主机的Spring Boot应用无法直接访问Docker容器的内部网络
3. 手动修改KAFKA_ADVERTISED_LISTENERS会覆盖Testcontainers默认的适配配置，导致广播地址和实际对外暴露的地址不匹配

修复方案 #

• 直接调用KafkaContainer官方提供的getBootstrapServers()方法获取正确的对外连接地址，无需手动拼接地址，测试类修改后代码如下：

@RunWith(SpringRunner.class)
@Import(KafkaTestContainersConfiguration.class)
@SpringBootTest
@DirtiesContext
public class KafkaTestContainersLiveTest {    
    @ClassRule
    public static KafkaContainer kafka =
            new KafkaContainer(DockerImageName.parse("confluentinc/cp-kafka:5.4.3"));

    @BeforeClass
    public static  void setupBootstrapServer(){
        // 该方法会自动返回宿主机可访问的 主机IP+映射端口 格式的地址，无多余协议前缀
        System.setProperty("kafka.bootstrap.servers", kafka.getBootstrapServers());
    }
}

• 移除所有手动设置KAFKA_ADVERTISED_LISTENERS的逻辑，Testcontainers的KafkaContainer默认已经针对宿主机访问场景做了监听器适配，手动修改会导致地址映射异常
• 检查配置类中所有Kafka客户端的配置，确保没有硬编码localhost:9092的逻辑，所有bootstrap地址都读取注入的bootstrapServer变量

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