Kafka配置端口绑定及Testcontainers测试：配置未指向容器问题排查

当然可以在Testcontainers启动后覆盖Kafka端口配置，你的代码里存在几个关键问题导致配置未生效，以下是具体分析和修正方案：

问题诊断 #

1. 属性名不匹配：你的初始化器中设置的属性是kafka.config.bootstrap-server，但应用配置文件里实际使用的是spring.kafka.bootstrap-servers，属性键不一致导致覆盖无效。
2. 镜像标签错误：confluentinc/cp-kafka:6.2.1:arm64的标签格式有误，正确的ARM64镜像标签应为6.2.1-arm64，错误标签会导致容器启动异常或无法连接。
3. 多余网络配置：手动指定withNetwork(Network.newNetwork())会让容器脱离Testcontainers默认网络，导致应用无法访问容器内的Kafka服务。
4. 初始化器逻辑冗余：@DynamicPropertySource已经是Spring Boot集成Testcontainers的标准方式，额外的ApplicationContextInitializer属于重复操作，且未正确获取容器实例。

修正后的测试代码 #

@SpringBootTest
public class KafkaTestContainer {

    @Container
    @ServiceConnection
    public static KafkaContainer kafkaContainer = new KafkaContainer(
            DockerImageName.parse("confluentinc/cp-kafka:6.2.1-arm64"))
            .withEnv("KAFKA_AUTO_CREATE_TOPICS_ENABLE", "false")
            .withEmbeddedZookeeper();

    // 若无需@ServiceConnection，可单独使用此动态属性源覆盖配置
    @DynamicPropertySource
    static void kafkaProperties(DynamicPropertyRegistry registry) {
        registry.add("spring.kafka.bootstrap-servers", kafkaContainer::getBootstrapServers);
    }

    @Autowired
    private KafkaTemplate<String, String> kafkaTemplate;

    @Test
    void verifyKafkaConnection() throws Exception {
        // 验证bootstrap配置是否已指向Testcontainers实例
        String bootstrapServers = kafkaTemplate.getProducerFactory()
                .getConfigurationProperties().get("bootstrap.servers").toString();
        System.out.println("当前Bootstrap Servers: " + bootstrapServers);

        // 手动创建目标Topic（因禁用了自动创建）
        try (AdminClient adminClient = AdminClient.create(
                Map.of(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers))) {
            adminClient.createTopics(Collections.singleton(
                    new NewTopic("XXX", 1, (short) 1))).all().get(10, TimeUnit.SECONDS);
        }

        // 发送消息测试连接
        kafkaTemplate.send("XXX", "test-key", "test-value").get(10, TimeUnit.SECONDS);
    }
}

关键说明 #

• @ServiceConnection的作用：该注解会自动将Testcontainers Kafka实例的bootstrap-servers注入到Spring环境中，无需手动编写@DynamicPropertySource，两者共存时以@DynamicPropertySource的优先级更高。
• 无需手动映射端口：Testcontainers会自动为容器分配随机端口，getBootstrapServers()会返回正确的localhost:随机端口地址，手动映射9093端口会导致配置冲突。
• Topic创建验证：禁用自动创建Topic后，务必在发送消息前通过AdminClient在Testcontainers的Kafka实例中手动创建Topic，避免出现"Topic不存在"的错误。

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