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
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.
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?