java - 如何使用 java api 在 kafka 主题上设置 ACL？
问题描述
我正在尝试通过 Java 在 Apache Kafka 主题上设置acl 。我遇到了setAcl()Kafka 管理客户端中存在的方法。但不确定如何使用它。我有一个设置了 3 个代理的 Kafka 集群，并在其上应用了acl（服务器端）。
我需要在客户端用 java 实现它（我有所需的客户端证书）。请注意，我需要有关 java 代码的帮助（而不是使用 shell 脚本）
解决方案
推荐阅读
- package - 如何为 Symfony 创建一个作曲家包
- arrays - 使用 Nifi 将带有数组的 json 插入 BigQuery 的问题
- java - 如何使用多行文本呈现网页java spring boot
- angular - 使用 ngIf 单击外部指令？
- apache-kafka - kafka 中的最大消息保留
- gsm - 如何使用 energia 将 msp430G2553 与 GSM 模块连接
- php - 一次不能输入超过一个数字
- python - 程序不会循环回到其他选择
- node.js - Nodejs lambda函数api调用返回false
- python - cv2.imwrite 不保存图像