Java API kermerleştirilmiş ortamda kafka-acls.sh için?

Question

HDp 2.4 kerberleştirilmiş kullanıyorum. Dinamik olarak java API'sı aracılığıyla konu oluşturuyorum. Başarıyla oluşturuldu, ancak kafka-acls.sh kullanarak yaptığımız gibi, tüm kullanıcılara erişim sağlamak için bazı yardımcı olabilir.

sadece java aracılığıyla komuta altında çalıştırmak istedim:

kafka-acls.sh --add --allow-principals user:ctadmin --operation ALL --topic marchTesting --authorizer-properties zookeeper.connect={hostname}:2181 

Answer 1

Onun basit:

import kafka.admin.AclCommand;  

String[] cmdPArm = {"--add", "--allow-principals", "user:ctadmin", "--operation", "ALL","--topic", topicName ,"--authorizer-properties", "zookeeper.connect=hscale-dev1-dn1:2181,hscale-dev1-dn3:2181,hscale-dev1-dn2:2181"}; 
AclCommand.main(cmdPArm);