Spring Boot 3中EmbeddedKafka环境下KafkaTemplate无法发送消息排查

• 确认EmbeddedKafka启动与配置匹配

  • 检查测试类是否添加@EmbeddedKafka(topics = {"目标topic名"})注解，确保指定topic和发送、消费的完全一致
  • 验证application.yml中spring.kafka.bootstrap-servers是否和EmbeddedKafka实际端口匹配，可通过EmbeddedKafkaBroker.getBrokersAsString()打印实际地址做比对
  • 查看测试日志，确认EmbeddedKafka无启动异常（如端口冲突、依赖缺失）

• 排查KafkaTemplate发送逻辑

  • 发送消息时强制等待结果，比如使用kafkaTemplate.send("topic", "msg").get(5, TimeUnit.SECONDS)，捕获TimeoutException或ExecutionException，直接暴露具体报错（如序列化失败、topic不存在）
  • 检查producer配置：acks参数若设为all，需确保EmbeddedKafka副本数足够（默认单节点无问题）；序列化器需和consumer端一致（比如均为StringSerializer/StringDeserializer）
  • 确认KafkaTemplate Bean已正确注入，未被自定义配置覆盖导致参数异常

• 验证Consumer监听配置

  • 检查@KafkaListener注解的topics参数是否和发送的topic完全匹配，无拼写或大小写错误
  • 确保consumer的group-id唯一，避免测试间状态冲突；auto-offset-reset设为earliest，防止错过已发送的消息
  • 检查监听方法的参数类型是否和消息value类型匹配，排查方法内是否有吞掉异常的try-catch块（如捕获Exception但未打印日志，导致断点不触发）
  • 确认Consumer Bean已被Spring上下文正确初始化，测试类需添加@SpringBootTest或@ContextConfiguration加载相关配置

• 开启Debug日志定位问题
  在test/resources/application.yml中添加日志配置，查看Kafka底层交互细节：

  logging:
    level:
      org.apache.kafka: DEBUG
      org.springframework.kafka: DEBUG
  

  通过日志确认：producer是否发送请求、收到Broker确认；consumer是否订阅topic、拉取消息，有无异常堆栈

• 代码细节检查

  • 发送消息前，可调用embeddedKafkaBroker.waitForAssignment(consumer, topic)，确保consumer已完成分区分配，避免消息发送后consumer未就绪
  • 排查自定义的ProducerFactory/ConsumerFactory是否修改了核心配置（如bootstrap-servers未指向EmbeddedKafka）

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