我正在尝试通过 Java 在 Apache Kafka 主题上设置acl 。我遇到了setAcl()Kafka 管理客户端中存在的方法。但不确定如何使用它。我有一个设置了 3 个代理的 Kafka 集群，并在其上应用了acl（服务器端）。
我需要在客户端用 java 实现它（我有所需的客户端证书）。请注意，我需要有关 java 代码的帮助（而不是使用 shell 脚本）
问问题
653 次
我正在尝试通过 Java 在 Apache Kafka 主题上设置acl 。我遇到了setAcl()Kafka 管理客户端中存在的方法。但不确定如何使用它。我有一个设置了 3 个代理的 Kafka 集群，并在其上应用了acl（服务器端）。
我需要在客户端用 java 实现它（我有所需的客户端证书）。请注意，我需要有关 java 代码的帮助（而不是使用 shell 脚本）