配置SASL_PLAINTEXT认证Kafka遇JAAS无KafkaServer条目错误

配置采用SASL_PLAINTEXT认证的Kafka服务时，出现错误提示：Could not find a 'KafkaServer' entry in the JAAS configuration。已查阅Stack Overflow相关方案但未解决，寻求新的排查思路。

相关配置信息 #

server.properties #

broker.id=0
listeners=INTERNAL://127.0.0.1:9092
advertised.listeners=INTERNAL://127.0.0.1:9092
listener.security.protocol.map=INTERNAL:SASL_PLAINTEXT
num.network.threads=3
num.io.threads=8
socket.send.buffer.bytes=102400
socket.receive.buffer.bytes=102400
socket.request.max.bytes=104857600
log.dirs=/tmp/kafka-logs
num.partitions=1
num.recovery.threads.per.data.dir=1
offsets.topic.replication.factor=1
transaction.state.log.replication.factor=1
transaction.state.log.min.isr=1
log.retention.hours=168
log.segment.bytes=1073741824
inter.broker.listener.name=INTERNAL

log.retention.check.interval.ms=300000
zookeeper.connect=127.0.0.1:2181
zookeeper.connection.timeout.ms=18000
group.initial.rebalance.delay.ms=0
delete.topic.enable=true
sasl.enabled.mechanisms=SCRAM-SHA-256
sasl.mechanism.inter.broker.protocol=SCRAM-SHA-256
ssl.endpoint.identification.algorithm=

kafka_server_jaas.conf #

KafkaServer {
   org.apache.kafka.common.security.scram.ScramLoginModule required
   username="admin"
   password="123456";
   };
Client {
   org.apache.kafka.common.security.plain.PlainLoginModule required
   username="admin"
   password="123456";
   };

执行的命令 #

export KAFKA_OPTS="-Djava.security.auth.login.config=/home/username/kafka/config/kafka_server_jaas.conf"
sudo bin/kafka-server-start.sh config/server.properties # 在Kafka目录下执行

执行echo $KAFKA_OPTS得到结果：-Djava.security.auth.login.config=/home/kafka/kafka/config/kafka_server_jaas.conf

排查思路 #

• sudo环境变量传递问题：用sudo执行命令时，默认不会继承当前用户的环境变量，导致KAFKA_OPTS没传给Kafka进程。可以用sudo -E保留环境变量，或者直接在sudo命令里指定变量：

  sudo -E bin/kafka-server-start.sh config/server.properties
  # 或者
  sudo KAFKA_OPTS="-Djava.security.auth.login.config=/home/username/kafka/config/kafka_server_jaas.conf" bin/kafka-server-start.sh config/server.properties
  

• JAAS文件路径不一致：echo $KAFKA_OPTS显示的路径是/home/kafka/kafka/config/kafka_server_jaas.conf，但执行命令里写的是/home/username/kafka/config/kafka_server_jaas.conf，先确认文件实际位置是否正确，同时检查Kafka进程有没有读取该文件的权限。
• JAAS配置机制不匹配：当前内部broker通信用的是SCRAM-SHA-256，但JAAS里的Client块用的是PlainLoginModule，两者不匹配，需要把Client块改成ScramLoginModule：

  Client {
     org.apache.kafka.common.security.scram.ScramLoginModule required
     username="admin"
     password="123456";
     };
  

• 直接在启动脚本中指定配置：如果环境变量传递总是出问题，可以修改kafka-server-start.sh脚本，在启动命令里直接添加-Djava.security.auth.login.config=/path/to/kafka_server_jaas.conf参数，跳过环境变量依赖。
• JAAS文件语法与版本兼容性检查：确认KafkaServer块的语法正确（比如分号、引号是否闭合），同时检查ScramLoginModule的类名是否和当前Kafka版本兼容（低版本Kafka可能不支持SCRAM认证模块）。

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