i am using kafka version 0.9.0 using two kafka brokers. 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: get /brokers/ids/1002 {"jmx_port":-1,"timestamp":"1490888565689","endpoints":["PLAINTEXTSASL://xxxx.domain.com:9092"],"host":null,"version":2,"port":-1} 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. get /brokers/ids/1002 {"jmx_port":-1,"timestamp":"1490888108079","endpoints":["PLAINTEXT://0.0.0.0:9092"],"host":"xxxx.domain.com","version":2,"port":9092} cZxid = 0x1300000230 ctime = Thu Mar 30 21:05:08 IST 2017 mZxid = 0x1300000230 mtime = Thu Mar 30 21:05:08 IST 2017 pZxid = 0x1300000230 cversion = 0 dataVersion = 0 aclVersion = 0 ephemeralOwner = 0x25b1439a48c001a dataLength = 161 numChildren = 0 can anyone help? TIA. ... View more