Kubernetes环境Bitnami Kafka连接认证失败问题求助

1. 确认user1是有效用户名 #

Bitnami Kafka Helm Chart的默认values.yaml中确实配置了user1作为默认客户端用户，因此它是该Kafka实例的有效用户名。

2. 排查认证失败的核心原因 #

（1）修复client.properties的语法错误 #

你的client.properties中sasl.jaas.config的密码部分存在语法问题：密码的闭合引号位置错误，且分号放置不当。正确的配置应该是：

security.protocol=SASL_PLAINTEXT
sasl.mechanism=SCRAM-SHA-256
sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required \
    username="user1" \
    password="$(kubectl get secret kafka-user-passwords --namespace kafka -o jsonpath='{.data.client-passwords}' | base64 -d | cut -d , -f 1)";

注意：分号需要放在密码引号的外面，且要保证命令替换的部分被正确闭合在引号内。

（2）验证密码与用户名的对应关系 #

Bitnami Kafka的kafka-user-passwords Secret中，client-users和client-passwords是按顺序一一对应的逗号分隔字符串。请先确认user1在用户名列表中的位置，再获取对应密码：

• 获取客户端用户名列表：

  kubectl get secret kafka-user-passwords -n kafka -o jsonpath='{.data.client-users}' | base64 -d
  

  若输出为user1,user2，则user1是第一个用户，对应密码为client-passwords的第一个值。
• 手动提取user1的密码：

  kubectl get secret kafka-user-passwords -n kafka -o jsonpath='{.data.client-passwords}' | base64 -d | cut -d , -f 1
  

  可以将此密码直接写入client.properties（替换命令替换部分），测试是否能正常认证。

（3）在Kafka客户端容器内验证配置 #

进入客户端容器后，先确保/tmp/client.properties的内容正确，再执行生产者命令：

# 查看配置文件内容，确认密码和语法无误
cat /tmp/client.properties

# 执行生产者命令
kafka-console-producer.sh \
            --producer.config /tmp/client.properties \
            --bootstrap-server kafka.kafka.svc.cluster.local:9092 \
            --topic test

3. 额外检查项 #

• 确认Kafka集群的认证配置：Bitnami Kafka默认启用SCRAM-SHA-256认证，若你未修改values.yaml中的auth.clientProtocol配置，则无需额外调整。
• 检查网络连通性：确保客户端容器能正常访问kafka.kafka.svc.cluster.local:9092，可通过telnet kafka.kafka.svc.cluster.local 9092测试。

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