java - 使用Java代码的Kafka ACL授权问题

Question

我想通过 java 应用程序授予对 kafka 主题的访问权限，就像我们通过 kafka-acls.sh 所做的那样。我只是想通过 java api 运行下面的命令。

kafka-acls.sh --add --allow-principals User:ctadmin --operation ALL --topic test --authorizer-properties zookeeper.connect=localhost:2181

我使用这些 Java 指令来执行此操作(topicName 具有 test 作为值):

String[] cmdPArm = {"--add", "--allow-principals", "User:ctadmin", "--operation", "ALL","--topic", topicName ,"--authorizer-properties", "zookeeper.connect=localhost:2181"};
AclCommand.main(cmdPArm);

该命令运行没有任何问题。 ACL 授权已设置，但我对该命令的工作方式有一些疑问。当我尝试获取主题的当前权限时，而不是以下输出:

Current ACLs for resource `Topic:test`: 
    User:ctadmin has Allow permission for operations: All from hosts: localhost

我有这个:

Current ACLs for resource `Topic:test`: 
    user:ctadmin has Allow permission for operations: All from hosts: localhost

您可以看到 user:ctadmin 和 User:ctadmin 之间的区别，它没有为我的用户正确授予权限，并且我无权使用此权限主题。

我该如何解决这个问题？

Answer 1

问题已解决。这可能是由于缓存中存在一些旧数据造成的。我在另一台主机上进行了全新的 Kafka 安装/配置，一切正常。