步驟

搭建kafka單機環境時，使用版本是kafka_2.11-1.0.0.tgz，步驟是按官網的介紹如下：

1.   下載1.0.0release 並解壓。

1)       tar -xzf kafka_2.11-1.0.0.tgz

2)   cd kafka_2.11-1.0.0

2.       啟動服務

bin/zookeeper-server-start.shconfig/zookeeper.properties

啟動服務：

bin/kafka-server-start.shconfig/server.properties

3.       建立topic

建立一個名為“test”的單分割槽、單replica的主題：

bin/kafka-topics.sh --create--zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

檢視topic：

bin/kafka-topics.sh --list --zookeeper localhost:2181

4.       傳送訊息

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

This is a message

This is anothermessage

5.       接收訊息

bin/kafka-console-consumer.sh --bootstrap-serverlocalhost:9092 --topic test --from-beginning

This is a message

This is anothermessage

問題

按上述步驟執行到5，接收訊息時，會出現以下的錯誤資訊：

[2017-11-27 13:02:40,618] WARN [Controllerid=0, targetBrokerId=0] Connection to node 0 could not be established. Brokermay not be available. (org.apache.kafka.clients.NetworkClient)

解決：

Vim config/server.properties

發現zookeeper.connect= localhost:2181的設定是localhost，則修改server.properties，新增：

listeners=PLAINTEXT://localhost:9092

重新啟動zookeeper、kafka、consumer、producer即可解決問題。