WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

[#1]

WARN [Producer clientId=console-producer] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

When I try to ping from producer command , I'm getting the above error.

Kafka 1.0.1 and Zookeeper are running mode only

[#2]

Go to ambari >> kafka >> configs type "listeners" in the filter, check for the port number given there

listeners = PLAINTEXT://localhost:6667 . use the port number mentioned here for consumer-producer and try again.

[#3]

I am getting similar warning log when my consumer when broker is down.

is there a way my consumer code get notify when all brokers are down? and when broker are back?