Spring Boot Kafka生产者如何连接企业远程Kafka服务器并解决认证报错

生产者基础配置说明 #

• spring.kafka.bootstrap-servers是全局通用配置，生产者、消费者、AdminClient都会复用该配置，无需单独为生产者定义。
• spring.kafka.consumer.group-id确实是消费者专属配置，生产者不需要设置，生产者特有的配置均以spring.kafka.producer.为前缀，基础连接场景下无需额外配置生产者专属参数。

认证报错解决方案 #

你遇到的Connection terminated during authentication报错是因为缺少完整的安全认证配置，从你贴出的运行时配置可以看到，SSL相关的信任库、密钥库配置均为空，且默认的SASL认证机制没有对应配置，导致和服务端握手失败，按以下步骤处理：

1. 向公司基础设施运维团队获取Kafka集群的访问凭证，确认认证方式：
   • 如果是SSL认证，需要获取服务端信任库（truststore）文件、对应访问密码，双向认证场景还需要额外获取客户端密钥库（keystore）文件及对应密码
   • 如果是SASL+SSL认证，需要获取对应认证机制的身份凭证（如SCRAM的账号密码、Kerberos的keytab等）
2. 确认网络连通性：本地执行telnet kafka1.mycompany.com 9092验证端口可通，排除防火墙拦截问题
3. 补充对应配置到application.properties中，以下为两种常见场景的配置示例：

场景1：SASL_SCRAM + SSL单向认证 #

spring.kafka.bootstrap-servers=kafka1.mycompany.com:9092,kafka2.mycompany.com:9092
spring.kafka.security.protocol=SASL_SSL
# SSL信任库配置
spring.kafka.ssl.truststore-location=classpath:kafka.truststore.jks
spring.kafka.ssl.truststore-password=运维提供的信任库密码
# SASL认证配置
spring.kafka.sasl.mechanism=SCRAM-SHA-256
spring.kafka.sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required username="你的账号" password="你的密码";

场景2：SSL双向认证 #

spring.kafka.bootstrap-servers=kafka1.mycompany.com:9092,kafka2.mycompany.com:9092
spring.kafka.security.protocol=SSL
# 信任库配置
spring.kafka.ssl.truststore-location=classpath:kafka.truststore.jks
spring.kafka.ssl.truststore-password=信任库密码
# 客户端密钥库配置
spring.kafka.ssl.keystore-location=classpath:kafka.keystore.jks
spring.kafka.ssl.keystore-password=密钥库密码
spring.kafka.ssl.key-password=密钥访问密码

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