嵌入式Kafka集成测试Consumer端latch未归零导致Gradle运行超时

核心原因（按出现概率从高到低排序） #

• 硬编码嵌入式Kafka端口：你在测试类的@EmbeddedKafka注解中固定了端口9092，IDEA运行时该端口大概率空闲，而Gradle运行测试时，可能存在端口占用、多测试任务并行跑端口冲突的问题，导致嵌入式Kafka启动失败，生产者连接不上。
• 配置键不匹配：你自定义的KafkaProducerConfig中注入的是${kafka.bootstrap-address}，但application.yml里配置的Kafka地址是spring.kafka.bootstrap-servers，两者配置名不一致，导致生产者拿到的连接地址为空或者错误值。IDEA运行时可能你在本地配置了环境变量、启动参数覆盖了该值所以能正常运行，Gradle运行时没有对应配置就会连接失败。
• IPv4/IPv6解析冲突：Gradle测试默认会启动独立JVM进程，部分系统的hosts配置中localhost会优先解析为IPv6地址::1，你配置的监听器绑定localhost:9092时Kafka会绑定到IPv6地址，而Spring Boot Kafka客户端默认优先连接IPv4的127.0.0.1:9092，导致连接失败，IDEA运行时JVM参数可能默认优先用IPv4所以不受影响。
• 配置类未生效：你贴出的KafkaProducerConfig代码没有加@Configuration注解，若实际代码也没加，Spring不会自动扫描加载该配置类的Bean，IDEA的宽松扫描规则可能会识别到，Gradle严格模式下就会加载失败。
• 消费者反序列化器缺失：你application.yml中只配置了消费者的偏移量重置策略和组ID，没有配置字符串反序列化器，默认使用字节数组反序列化器，可能存在解析异常导致消费者报错没有执行latch.countDown()。

修复步骤 #

1. 修改@EmbeddedKafka注解，删除硬编码的端口和监听器配置，让其自动分配空闲端口，Spring Boot会自动将分配的端口同步到spring.kafka.bootstrap-servers配置项：

@EmbeddedKafka(partitions = 1, brokerProperties = {"listeners=PLAINTEXT://127.0.0.1:0"})

这里0代表随机端口，同时指定绑定到IPv4的127.0.0.1避免地址解析问题。
2. 修改KafkaProducerConfig中的注入配置，和Spring Boot标准配置项对齐，同时给配置类加上@Configuration注解：

@Configuration
public class KafkaProducerConfig {
    @Value(value = "${spring.kafka.bootstrap-servers}")
    private String bootstrapAddress;
    // 其余代码不变
}

3. 在application.yml中补充消费者的反序列化器配置：

spring:
  kafka:
    bootstrap-servers: localhost:9092
    consumer:
      auto-offset-reset: earliest
      group-id: my-id
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.apache.kafka.common.serialization.StringDeserializer

4. 修复KafkaProducer类中的@Value注解语法错误（缺少${}），虽然本次测试未用到该变量，但后续使用会出错：

@Value(value = "${kafka.topic-name}")
String topicName;

5. 可以给await方法添加超时时间，避免测试永久挂住，便于排查问题：

// 最多等待10秒
boolean awaitResult = consumer.getLatch().await(10, TimeUnit.SECONDS);
assertThat(awaitResult, equalTo(true));

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