kafka-acls.sh --list failed when zookeeper SASL/PLAIN authentication is enabled

2018-12-26 Thread hui happy
I have a kakfa/zookeeper(embedded zookeeper) cluster with SASL/PLAIN + ACL enabled. It worked fine with version kafka_2.12-1.0.0. But recently, I need to upgrade to kafka_2.12-2.1.0. Unfortunately, the ACL function cannot work normally. kafka-acls.sh command failed, for example: > # echo $KAFKA_O

Is kafka support dynamic ACL rule

2018-12-26 Thread hui happy
Hi As I learned that kafka can use '--resource-pattern-type prefixed' to add rule for prefixed topic. For example an user 'kafkaclient', we could define a rule let the user can access all topics start with that user name, i.e., 'kafkaclient--', such as 'kafkaclient--topic1', 'kafkaclient--topic