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. ... View more