自己動(dòng)手寫了一個(gè)kafka消費(fèi)實(shí)例焰坪，但是執(zhí)行時(shí)總是報(bào)錯(cuò)：
2018-06-19 15:40:24.146 INFO AbstractCoordinator - [Consumer clientId=consumer-1, groupId=dfp] Marking the coordinator localhost:9092 (id: 2147483647 rack: null) dead
2018-06-19 15:40:25.153 WARN NetworkClient - [Consumer clientId=consumer-1, groupId=dfp] Connection to node 0 could not be established. Broker may not be available.
2018-06-19 15:40:26.206 WARN NetworkClient - [Consumer clientId=consumer-1, groupId=dfp] Connection to node 0 could not be established. Broker may not be available.
2018-06-19 15:40:27.311 WARN NetworkClient - [Consumer clientId=consumer-1, groupId=dfp] Connection to node 0 could not be established. Broker may not be available.
2018-06-19 15:40:28.514 WARN NetworkClient - [Consumer clientId=consumer-1, groupId=dfp] Connection to node 0 could not be established. Broker may not be available.
在kafka的配置文件server.properties中添加設(shè)置如下：
listeners=PLAINTEXT://10.100.1.200:9092
即可解決問題趣倾。
