如何使用Java从Kafka中删除ACL

Question

我正在尝试使用Java程序从KAFKA删除ACL。但是在删除时，安全检查

您确定要删除ACL：

我正在寻找禁用此安全检查或删除武力选项。

Answer 1

从0.10.0.0升级为kafka 0.10.1.0，其中 AclCommand中可用的强制删除选项（scala component）。添加--force参数后--remove。

恰好工作语法：

String[] cmdPArm = {"--authorizer-properties", "zookeeper.connect=localhost:2181",
                    "--remove", "--force", "--allow-principal", "User:*",
                    "--allow-host", "17.129.0.99",
                    "--operation", "Read",  "--operation", "Write",
                    "--topic", "myTopic"};
AclCommand.main(cmdPArm);