@DynamicPropertySource无法覆盖KafkaProperties问题求助

核心原因 #

1. 未启用@Testcontainers注解：缺少该注解时，Testcontainers容器的生命周期无法与Spring测试上下文同步，导致@DynamicPropertySource在KafkaProperties初始化后才执行，无法覆盖默认配置。
2. 手动启动容器打乱顺序：在@DynamicPropertySource中调用kafka.start()会绕过Testcontainers的生命周期管理，导致容器启动时机晚于Spring Bean的初始化。
3. Bootstrap地址获取错误：手动拼接localhost:9093映射端口存在风险，KafkaContainer内部默认端口是9092，且容器提供了getBootstrapServers()方法直接返回正确的连接地址。

修复步骤 #

1. 启用@Testcontainers注解 #

在抽象测试类上添加@Testcontainers注解，让Spring测试与Testcontainers生命周期绑定：

@Log4j2
@AutoConfigureMetrics
@TestPropertySource(locations = "classpath:application-test.properties")
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = {Application.class})
@AutoConfigureWireMock(port = 0)
@Testcontainers // 启用Testcontainers生命周期管理
@Import(KafkaTestContainerConfig.class)
public abstract class AbstractIntegrationTest {
    ...
}

2. 修正KafkaTestContainerConfig配置 #

移除手动启动代码，改用容器内置方法获取Bootstrap地址：

@Configuration
public class KafkaTestContainerConfig {

    @Container
    public static KafkaContainer kafka = new KafkaContainer(
        DockerImageName.parse("confluentinc/cp-kafka:7.2.2.arm64"))
        .withEnv("KAFKA_AUTO_CREATE_TOPICS_ENABLE", "true")
        .withEnv("KAFKA_CREATE_TOPICS", "my-topic")
        .withEmbeddedZookeeper();


    @DynamicPropertySource
    public static void addKafkaProperties(DynamicPropertyRegistry registry) {
        // 移除手动start()，@Testcontainers会自动启动容器
        registry.add("spring.kafka.bootstrap-servers", kafka::getBootstrapServers);
    }
}

3. 验证依赖加载顺序 #

若defaultKafkaProducer Bean仍存在提前初始化问题，可添加@Lazy注解延迟加载（正确配置Testcontainers后通常无需此操作）：

@Bean
// 可选：延迟加载Bean，确保容器启动后再初始化
@Lazy
public <T> KafkaProducer<String, T> defaultKafkaProducer(KafkaProperties kafkaProperties) {
    Map<String, Object> props = new HashMap<>();
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaProperties.getBootstrapServers());
    ...
}

原理说明 #

@Testcontainers注解会触发Testcontainers的Spring测试集成逻辑：

• 在Spring上下文初始化之前启动标记了@Container的静态容器实例；
• 确保@DynamicPropertySource方法在Spring加载配置属性（包括KafkaProperties）之前执行，从而动态覆盖spring.kafka.bootstrap-servers配置；
• 测试结束后自动停止并清理容器。

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