Spring Kafka 本身不内置 Kafka 服务，仅提供客户端 API；报错 “Connection to node -1 could not be established” 表明应用尝试连接 localhost:9092 失败——你需要自行部署并启动一个真实的 Kafka Broker。
spring kafka 连接失败：必须手动启动本地 kafka 服务
Spring Kafka 是一个纯客户端框架，它封装了 Apache Kafka 的 Producer、Consumer 和 Admin API，但绝不包含 Kafka 服务端（Broker）。因此，当你看到日志中反复出现 Connection to node -1 (localhost/127.0.0.1:9092) could not be established，本质原因非常明确：Kafka Broker 并未运行，Spring 应用自然无法建立连接。
这与 Spring Boot 内嵌 Tomcat 不同——Tomcat 是 Web 容器，由 Spring Boot 自动拉起；而 Kafka 是独立的分布式消息系统，需单独部署、配置和启动。Spring Kafka 不会、也不能“自动部署” Kafka。
✅ 正确理解 Embedded Kafka 的作用范围
Spring Kafka 确实提供了 @EmbeddedKafka 注解，但它仅限单元测试使用，底层基于 kafka-clients 和内存模拟机制，不等价于真实 Kafka 集群，且默认不启用、不暴露外部端口（如 9092），也无法被主应用上下文直接复用。示例：
@SpringBootTest
@EmbeddedKafka(topics = "test-topic", partitions = 1)
class KafkaIntegrationTest {
@Autowired
private KafkaTemplate<String, String> template;
@Test
void shouldSendAndReceive() {
template.send("test-topic", "hello");
// …
}
}⚠️ 注意：该注解仅在测试类中生效，对 application.yml 中配置的 bootstrap-servers: localhost:9092 无任何影响。
✅ 如何正确启动本地 Kafka（推荐 KRaft 模式）
自 Kafka 3.3+ 起，官方已弃用 ZooKeeper 依赖，全面转向轻量、高性能的 KRaft（Kafka Raft Metadata mode）。以下是 Linux/macOS 下快速启动步骤（Windows 用户请使用 windows/ 目录下的 .bat 脚本）：
下载并解压 Kafka
访问 kafka.apache.org/downloads，下载二进制包（如kafka_2.13-3.7.0.tgz），解压后进入目录。-
生成集群 ID 并格式化存储目录
# 进入 kafka 目录 cd kafka_2.13-3.7.0 # 生成唯一集群 ID export KAFKA_CLUSTER_ID=$(bin/kafka-storage.sh random-uuid) # 格式化日志目录（注意：修改 /tmp/kraft-combined-logs 为可写路径，如 ./data/kraft-logs） mkdir -p ./data/kraft-logs bin/kafka-storage.sh format -t $KAFKA_CLUSTER_ID -c config/kraft/server.properties
-
配置 server.properties（关键！）
编辑config/kraft/server.properties，确保以下配置项正确：listeners=PLAINTEXT://:9092 advertised.listeners=PLAINTEXT://localhost:9092 controller.listener.names=CONTROLLER listener.security.protocol.map=CONTROLLER:PLAINTEXT,PLAINTEXT:PLAINTEXT log.dirs=./data/kraft-logs
✅
advertised.listeners必须设为localhost:9092，否则 Spring 客户端将尝试连接错误地址（如192.168.x.x:9092）。 -
启动 Kafka Broker
bin/kafka-server-start.sh config/kraft/server.properties
启动成功后，控制台将输出
Kafka Server started，此时netstat -an | grep 9092应可见监听状态。
✅ 验证连接（可选）
使用 Kafka 自带工具快速验证：
# 创建主题（可选，Spring Kafka 的 NewTopic Bean 会自动创建） bin/kafka-topics.sh --create --topic test-topic --partitions 1 --replication-factor 1 --bootstrap-server localhost:9092 # 查看主题列表 bin/kafka-topics.sh --list --bootstrap-server localhost:9092
? 总结与最佳实践
- ❌ 不要期待 Spring Kafka 自动启动 Kafka 服务；
- ✅ 生产/开发环境必须独立部署 Kafka Broker（推荐 KRaft 模式）；
- ✅
advertised.listeners配置错误是本地连接失败的最常见原因； - ✅ 若仅用于测试，优先使用
@EmbeddedKafka+@SpringBootTest，而非试图“连本地 9092”； - ✅ 在
application.yml中保留spring.kafka.bootstrap-servers: localhost:9092是正确的，前提是 Kafka 真正在该地址运行。
完成上述步骤后，重启你的 Spring Boot 应用，AdminClient 将成功连接节点，NewTopic Bean 会自动创建主题，整个 Kafka 流程即可正常运转。
