2017-08-09 83 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(); 
相關問題