After we enable the kerberos, the kafka producer starts showing leadernotfound exception where as the describe command shows that leader is assigned to the topic.
Also,i noticed something weird about kafka znode as follows:
If we try to get the information for kafka broker znode after enabling kerberos, it shows as below:
cZxid = 0x1300000241
ctime = Thu Mar 30 21:12:45 IST 2017
mZxid = 0x1300000241
mtime = Thu Mar 30 21:12:45 IST 2017
pZxid = 0x1300000241
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x15b1439a498001a
dataLength = 140
numChildren = 0
The host and the port information is not getting configured. I tried configuring these(advertised.host.name and advertised.port) through ambari as well as setting proprty in server.properties file and restarting the kafka manually but it is not getting reflected.
But, if i change the protocol from PLAINTEXTSASL/SASL_PLAINTEXT to simply PLAINTEXT then the host and port information is gets updated correctly as below.