执行：

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

kafka出现:

 Error while fetching metadata with correlation id   : {LEADER_NOT_AVAILABLE}

表示无法识别kafka hostname

处理方式：

1、修改server.properties如下，目的是让kafka监听的到

vi   /opt/kafka/kafka/config/server.properties

再次启动即可在produce端输入，在消费端看到输出。

2.测试

  bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning

以上仅为本地服务器操作可行，远程访问就会报

o.a.kafka.common.network.Selector - Connection with /192.168.176.136 disconnected
java.net.ConnectException: Connection refused: no further information

如果要本地和远程访问都没有问题，解决如下:

(1)  ps -ef | grep kafka

    kill -9   kafka的pid

(2)ps -ef | grep zookeeper

   kill -9  zookeeper的pid

(3)修改/opt/kafka/kafka/config/server.properties

(4)

进行远程telnet测试

telnet  IP:9092

测试成功