I install Kafka in Ambari and configure two listeners for every broker, one for inner traffic and one for outer traffic. E.g., broker A has two ip addresses: 192.168.1.1 and 88.88.88.88, and its configuration is like follows:   SASL_PLAINTEXT://192.168.1.1:9092,EXTERNAL://88.88.88.88:19092 listener.security.protocol.map=SASL_PLAINTEXT:SASL_PLAINTEXT,EXTERNAL:SASL_PLAINTEXT security.inter.broker.protocol=SASL_PLAINTEXT   With this configurations, Kafka works fine but keeps alerting, the message is:   Connection failed: [Errno 111] Connection refused to 192.168.1.1:19092    This is not valid because ip and port do not match. And I suspect that it could just split by colon and use the last element. So I exchange the order of the two listeners:   EXTERNAL://88.88.88.88:19092,SASL_PLAINTEXT://192.168.1.1:9092   To my surprise, it still alerts and the message changes to    Connection failed: [Errno 111] Connection refused to 88.88.88.88:9092   ip and port still do not match ?  Have anybody also run into this or am I misconfiguring something ? Or this is a bug ? ... View more

The reason why I am asking this is a little complicated. So I will not mention too much about it (unless somebody is interested). In fact, I have more than one question.   1. When Kerberos is enabled, does CM add service principals based on hostname shown/stored in CM or every host's actual hostname ? Otherwise, are they always the same ? 2. If hostnames in CM can be different from actual hostnames, how do I achieve that ? (I have tried changing database records and the host cannot connect to HostMonitor afterwards)   Thanks. ... View more

I have enabled Kerberos authentication for Kafka as the documentation suggests and indeed producing to topics and consuming from topics requires authentication. Surprisingly, topic creation and deletion do not require authentication. Could somebody tell me whether this goes wrong ? Really appreciate it.   CDH version: 5.15.1 CDK version: 4.1.0 test command:     kafka-topics --create --zookeeper <zookeeper-host>:2181 --replication-factor 2 --partitions 3 --topic test2 kafka-topics --delete --zookeeper <zookeeper-host>:2181 --topic test2       ... View more