@Karan Alang Seems like 'kafka1' is a unix user and your mit kdc does not know about it. So you have register user with kdc and create keytab for the user. Please follow the below steps. 1. Run kadmin.local
2. In the kadmin prompt, run this command 'addprinc -randkey kafka1'
3. Then this command: 'xst -k /tmp/keytabs/kafka1.headless.keytab kafka1'
This should actually create the keytab and register user kafka1 in kdc. Now you can do the kinit with the kafka1 keytab(from step2) and perform the operations. If you have ranger configured in your cluster for kafka, you need to add appropriate policies in ranger. Hope this helps.
... View more
