2017-08-09 57 views
0

通常kafka-configs.sh用于使用该命令创建直接在动物园管理员SCRAM凭证/卡夫卡

> bin/kafka-configs.sh --zookeeper localhost:2181 --alter --add-config 'SCRAM-SHA-256=[iterations=8192,password=alice-secret],SCRAM-SHA-512=[password=alice-secret]' --entity-type users --entity-name alice 

是否有任何其他的方法来创建这些凭证来创建认证凭证SCRAM,无论是直接对动物园管理员或通过Java?

回答

0

Kafka Admin Client不提供创建SCRAM凭证的方法,我所做的是将kafka二进制文件下载到我的节点上,并使用java中的进程运行上述命令。

Process process = new ProcessBuilder(new String[] {"bash", "-c", cmdline}) 
         .redirectErrorStream(true) 
         .directory(new File(directory)) 
         .start(); 
相关问题