kafka-acls komutu

Giriş

Söz dizimi şöyle.

./bin/kafka-acls.sh 
  --authorizer-properties 
  zookeeper.connect=<zookeeper_host>:<zookeeper_port> 
  --add 
  --allow-principal <principal> 
  --operation <operation> 
  --topic <topic_name> 
  --group <consumer_group>

Principal

Principal olarak * kullanılabilir

Örnek

Şöyle yaparız

./bin/kafka-acls.sh 
  --authorizer-properties 
  zookeeper.connect=<zookeeper_host>:<zookeeper_port> 
  --add 
  --allow-principal * 
  --operation <operation> 
  --topic <topic_name> 
  --group <consumer_group>

--allow-principal seçeneği

belirtilen kullanıcıya izin verir

 --deny-principal  seçeneği

belirtilen kullanıcıya ait izini iptal eder

--operation Seçeneği

Operation olarak Read, Write, Create, Describe kullanılabilir

Örnek

Kullanıcıya read ve write izni vermek için şöyle yaparız

bin/kafka-acls.sh 
  --bootstrap-server $brokerssasl 
  --add 
  --allow-principal $dn 
  --operation Read 
  --operation Write 
  --topic test group=* 
  --command-config /path/to/client.properties