>From the example off: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Authorization+Command+Line+Interface
it seems following 'User:', the formation is te...@example.com Can you double check ? On Wed, Oct 4, 2017 at 8:55 PM, Awadhesh Gupta <awadhesh.in...@gmail.com> wrote: > Hi, > > I am working on Kafka Authorization using Kafka-ACL. I had enabled the > aithorization configuring following in server.properties file > > authorizer.class.name=kafka.security.auth.SimpleAclAuthorizer > super.users=User:CN=pxrdc.myhost.com > > I executed following command to add ACL on topic test > > ./bin/kafka-acls.sh --authorizer > kafka.security.auth.SimpleAclAuthorizer –authorizer-properties > zookeeper.connect=localhost:12181 \ > –add –allow-principal User:CN=pxrdc.myhost.com \ > --operation All –topic test > > Now, when I publish messages to Kafkabroker, I am getting following error > > $ bin/sasl-kafka-console-producer.sh --broker-list localhost:19092 --topic > test --producer.config config/client-sasl.properties > >message1 > [2017-10-05 16:09:52,001] WARN Error while fetching metadata with > correlation id 1 : {test=UNKNOWN_TOPIC_OR_PARTITION} > (org.apache.kafka.clients.NetworkClient) > [2017-10-05 16:09:52,001] WARN Error while fetching metadata with > correlation id 3 : {test=UNKNOWN_TOPIC_OR_PARTITION} > (org.apache.kafka.clients.NetworkClient) > > > If I open kafka-authorizer.log, I am seeing error for the same User to not > have access of Principal "User:CN=pxrdc.myhost.com" > > Want to understand if any specific configuration also needs to be added to > make it work. > > Thanks' > Awadhesh >