运行 Kafka ACL 命令失败答案

【问题标题】：Running Kafka ACL Commands fail运行 Kafka ACL 命令失败
【发布时间】：2020-04-24 11:22:16
【问题描述】：

我正在尝试从添加、删除和列出运行任何 kafka acl 命令。一个示例命令是：

../bin/kafka-acls.sh --authorizer-properties zookeeper.connect=localhost:2181 --add --allow-principal User:demouser --operation 创建 --operation 描述 --topic 演示主题

但我总是得到错误：

Error while executing ACL command: Exception while loading Zookeeper JAAS login context 'Client'
org.apache.kafka.common.KafkaException: Exception while loading Zookeeper JAAS login context 'Client'
    at org.apache.kafka.common.security.JaasUtils.isZkSecurityEnabled(JaasUtils.java:45)
    at kafka.admin.AclCommand$AuthorizerService.withAuthorizer(AclCommand.scala:197)
    at kafka.admin.AclCommand$AuthorizerService.addAcls(AclCommand.scala:221)
    at kafka.admin.AclCommand$.main(AclCommand.scala:70)
    at kafka.admin.AclCommand.main(AclCommand.scala)
Caused by: java.lang.SecurityException: java.io.IOException: /remote/sde108/kafka/kafka/config/config.conf (No such file or directory)
    at sun.security.provider.ConfigFile$Spi.<init>(ConfigFile.java:137)
    at sun.security.provider.ConfigFile.<init>(ConfigFile.java:102)
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
    at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
    at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
    at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
    at java.lang.Class.newInstance(Class.java:442)
    at javax.security.auth.login.Configuration$2.run(Configuration.java:255)
    at javax.security.auth.login.Configuration$2.run(Configuration.java:247)
    at java.security.AccessController.doPrivileged(Native Method)
    at javax.security.auth.login.Configuration.getConfiguration(Configuration.java:246)
    at org.apache.kafka.common.security.JaasUtils.isZkSecurityEnabled(JaasUtils.java:42)
    ... 4 more
Caused by: java.io.IOException: /remote/sde108/kafka/kafka/config/config.conf (No such file or directory)
    at sun.security.provider.ConfigFile$Spi.ioException(ConfigFile.java:666)
    at sun.security.provider.ConfigFile$Spi.init(ConfigFile.java:262)
    at sun.security.provider.ConfigFile$Spi.<init>(ConfigFile.java:135)
    ... 15 more

根据我的搜索，在 kafka 或 zookeeper 安装中没有名为 config.conf 的文件。有没有人遇到过类似的问题或同样的问题并且知道如何解决？

【问题讨论】：

假设您已经定义了一个加载该文件的环境变量。你能运行env | grep KAFKA吗？基本上，JAAS 配置可以指向任何地方，而不是 Kafka 提供的文件
知道了 cricket_007。发现 KAFKA_OPTS 指向那个奇怪的文件。只是将其更改为查看我的 kafka_server_jaas.conf 文件并修复了它。感谢您的帮助！

标签： apache-kafka apache-zookeeper acl jaas

【解决方案1】：

移动评论以回答。

根据错误，您以某种方式加载了 JAAS 文件。

这些可以在环境变量中设置，你会发现像env | grep KAFKA

【讨论】：