本文系统解析 Spring Boot 应用连接 Kafka（尤其是 Confluent Cloud 等云托管集群）时出现 Bootstrap broker localhost:9092 (id: -1) 或 Node -1 disconnected 错误的根本原因，涵盖配置加载机制陷阱、SASL/SSL 认证缺失、bootstrap.servers 覆盖逻辑、以及服务端网络参数适配等关键环节，并提供可直接落地的生产级配置方案。
本文系统解析 spring boot 应用连接 kafka（尤其是 confluent cloud 等云托管集群）时出现 `bootstrap broker localhost:9092 (id: -1)` 或 `node -1 disconnected` 错误的根本原因，涵盖配置加载机制陷阱、sasl/ssl 认证缺失、`bootstrap.servers` 覆盖逻辑、以及服务端网络参数适配等关键环节，并提供可直接落地的生产级配置方案。
在 Spring Boot 项目中集成 Kafka 时，开发者常被一条看似简单的 WARN 日志反复困扰：
WARN Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available.
更令人困惑的是：你已在 application.yml 中明确配置了远程地址（如 pkc-abc123.us-west-2.aws.confluent.cloud:9092），但客户端日志却固执地尝试连接 localhost:9092——这并非网络故障，而是 Spring Kafka 自动配置与显式 Bean 定义之间发生配置覆盖冲突的典型表现。
? 根本原因：Spring Boot 的“配置优先级陷阱”
Spring Kafka 的自动配置（KafkaAutoConfiguration）默认会读取 spring.kafka.bootstrap-servers 属性并创建 ProducerFactory。但一旦你手动声明 @Bean ProducerFactory，Spring 就*完全忽略所有 `spring.kafka.配置项**（包括security.protocol、sasl.mechanism、sasl.jaas.config` 等），仅使用你 Bean 中硬编码的 Map 参数。
这意味着：
- ✅ application.yml 中的 spring.kafka.properties.bootstrap.servers 不会生效；
- ❌ 所有 SASL/SSL 认证参数（如 sasl.jaas.config）若未显式注入到 ProducerFactory 的配置 Map 中，将被彻底丢弃；
- ⚠️ 客户端退回到默认配置：bootstrap.servers=localhost:9092 + security.protocol=PLAINTEXT → 必然连接失败，且日志显示 node -1（表示元数据尚未获取到任何可用 broker）。
✅ 正确做法：统一在 ProducerFactory 中声明全部必需参数
以下为适配 Confluent Cloud 的完整、可运行配置示例（兼容 Spring Boot 2.6+ / 3.x）：
@Configuration
public class KafkaConfiguration {
@Value("${spring.kafka.bootstrap-servers}")
private String bootstrapServers;
@Value("${spring.kafka.sasl.jaas.config}")
private String saslJaasConfig;
@Value("${spring.kafka.security.protocol}")
private String securityProtocol;
@Value("${spring.kafka.sasl.mechanism}")
private String saslMechanism;
@Bean
public ProducerFactory<string string> producerFactory() {
Map<string object> props = new HashMap();
props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class);
// ✅ 强制注入安全认证参数（关键！）
props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, securityProtocol); // "SASL_SSL"
props.put(SaslConfigs.SASL_MECHANISM, saslMechanism); // "PLAIN"
props.put(SaslConfigs.SASL_JAAS_CONFIG, saslJaasConfig); // "org.apache.kafka.common.security.plain.PlainLoginModule required username='...' password='...';"
// ✅ 生产级可靠性增强（推荐）
props.put(ProducerConfig.ACKS_CONFIG, "all");
props.put(ProducerConfig.ENABLE_IDEMPOTENCE_CONFIG, true);
props.put(ProducerConfig.RETRIES_CONFIG, 3);
props.put(ProducerConfig.LINGER_MS_CONFIG, 5);
props.put(ProducerConfig.BATCH_SIZE_CONFIG, 32768);
return new DefaultKafkaProducerFactory(props);
}
@Bean
public KafkaTemplate<string string> kafkaTemplate() {
return new KafkaTemplate(producerFactory());
}
}</string></string></string>
对应的 application.yml 配置（注意：此处仅用于属性占位，不参与自动配置）：
spring:
kafka:
bootstrap-servers: pkc-abc123.us-west-2.aws.confluent.cloud:9092
security-protocol: SASL_SSL
sasl-mechanism: PLAIN
sasl-jaas-config: org.apache.kafka.common.security.plain.PlainLoginModule required username='YOUR_API_KEY' password='YOUR_API_SECRET';
? 关键提示：Confluent Cloud 要求必须启用 SASL_SSL，且 bootstrap-servers 地址需严格匹配控制台提供的 fully qualified domain name (FQDN)，不可替换为 IP 或内网地址。
? 常见误区与避坑指南
| 误区 | 后果 | 正解 |
|---|---|---|
| 仅在 application.yml 中配置 spring.kafka.properties.* | SASL/SSL 参数被忽略，连接退化为 PLAINTEXT://localhost:9092 | 所有安全参数必须显式注入 ProducerFactory 的 Map |
| 使用 spring.kafka.bootstrap-servers 但未声明 ProducerFactory Bean | 可能成功（自动配置生效），但无法控制高级参数（如幂等、重试） | 推荐显式定义 Bean，实现配置可控性与可审计性 |
| sasl.jaas.config 值末尾缺少分号 ; | JAAS 解析失败，抛出 LoginException | 确保格式为 ...username='x' password='y';（结尾分号不可省略） |
| 未验证 Confluent Cloud ACL 权限 | 连接成功但 send() 报 TOPIC_AUTHORIZATION_FAILED | 登录 Confluent Console → Cluster → Access Control → 确认 API Key 具备 kafka-cluster:Describe, topic:Write 等权限 |
? 总结：连接成功的三要素
- 服务可达性：确保 bootstrap-servers 地址可从应用服务器 telnet 通（如 telnet pkc-abc123.us-west-2.aws.confluent.cloud 9092）；
- 认证完整性：SECURITY_PROTOCOL_CONFIG、SASL_MECHANISM、SASL_JAAS_CONFIG 三者缺一不可，且值必须精确匹配云平台要求；
- 配置一致性：拒绝混合使用自动配置与手动 Bean——要么全交由 Spring Boot 自动管理（删掉 ProducerFactory Bean），要么全由你显式定义（application.yml 仅作属性源）。
遵循以上原则，即可彻底告别 Node -1 disconnected 的无效连接尝试，让 Spring Boot 真正“按你所想”连接云端 Kafka 集群。
