KRaft模式下启用SASL_PLAINTEXT运行Kafka遇空指针错误求助

你的错误是因为在KRaft模式下使用了依赖ZooKeeper的AclAuthorizer授权器，而KRaft模式完全不需要ZooKeeper，导致授权器初始化时找不到ZK连接字符串，抛出NullPointerException。

1. 替换KRaft兼容的授权器类 #

修改server.properties中的授权器配置，替换为Kafka官方为KRaft模式提供的内置授权器：

authorizer.class.name=kafka.security.authorizer.ClusteredAuthorizationService

说明：ClusteredAuthorizationService从Kafka 2.8版本开始引入，专门适配KRaft架构，无需依赖ZooKeeper。

2. 清理无效配置 #

确保你的server.properties中没有任何ZooKeeper相关配置项（比如zookeeper.connect），KRaft模式下这些配置完全无用且会干扰初始化。

3. 修正SASL配置的格式问题 #

原配置中security.inter.broker.protocol的=后存在空格，可能导致解析异常，建议修正为：

security.inter.broker.protocol=SASL_PLAINTEXT

其余SASL相关配置保持现有内容即可。

4. 确保JAAS配置正确加载 #

启动Kafka前，必须通过环境变量指定JAAS配置文件的路径，示例命令：

export KAFKA_OPTS="-Djava.security.auth.login.config=/你的路径/kafka_jaas.conf"

执行该命令后再启动Kafka进程。

完成上述修改后，重新启动Kafka节点，即可正常启用SASL_PLAINTEXT认证并运行在KRaft模式下。

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