使用@ServiceConnection在KafkaContainer创建主题遇集成测试问题

核心问题分析 #

1. 手动指定spring.kafka.bootstrap-servers=localhost:9092覆盖了@ServiceConnection自动注入的容器实际地址（Docker容器默认使用随机映射端口，而非固定9092），导致应用无法连接到Kafka实例。
2. 使用了错误的环境变量TOPIC_AUTO_CREATE，Confluent Kafka的自动创建主题开关应为KAFKA_AUTO_CREATE_TOPICS_ENABLE。
3. 冗余的空安全配置可能带来潜在干扰，且未针对测试场景配置生产者容错属性。

修正后的测试类代码 #

@Testcontainers
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.NONE)
@ActiveProfiles("test")
class FullIntegrationTest extends Specification {

    @Bean
    @ServiceConnection
    KafkaContainer kafkaContainer() {
        // 推荐指定具体版本，避免latest标签的兼容性问题
        return new KafkaContainer(DockerImageName.parse('confluentinc/cp-kafka:7.5.0'))
                // 开启自动创建主题的正确环境变量
                .withEnv("KAFKA_AUTO_CREATE_TOPICS_ENABLE", "true")
                // 可选：提前创建指定主题，彻底避免元数据同步延迟问题
                .withCreateTopics(Topic.of("myTopic", 1, (short) 1))
    }
}

修正后的application-test.properties配置 #

spring.kafka.properties.schema.registry.url=mock://notused

# 移除手动指定的bootstrap-servers，交由@ServiceConnection自动注入容器地址
# 移除冗余的空安全配置，默认即为PLAINTEXT协议
# spring.kafka.properties.sasl.mechanism = ""
# spring.kafka.properties.security.protocol = PLAINTEXT
# spring.kafka.properties.basic.auth.credentials.source = ""
# spring.kafka.properties.schema.registry.basic.auth.user.info = ""
# spring.kafka.properties.sasl.jaas.config = ""

# 可选：配置生产者容错属性，应对Kafka启动初期的元数据同步延迟
spring.kafka.producer.properties.metadata.max.age.ms=5000
spring.kafka.producer.properties.request.timeout.ms=10000
spring.kafka.producer.retries=3

关键说明 #

• @ServiceConnection会自动将Kafka容器的实际连接地址注入到Spring Kafka配置中，无需手动指定bootstrap-servers。
• 使用withCreateTopics可以在容器启动时直接创建目标主题，避免依赖自动创建机制的延迟，确保测试流程开始时主题已存在。
• 增加生产者的超时和重试配置，可提升测试场景下的容错性，减少因Kafka实例启动未完成导致的元数据获取失败。

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