kafka 新版本命令 以及遇到問題匯總
阿新 • • 發佈：2018-09-28
list 持續更新 就是 node cti network rop 以及 per 搜了一圈百度，好多都是低版本的操作、特在這匯總一下2.0版本的一些命令，也和低版本做對比。
常用命令：
1、啟動命令：
前臺啟動
./bin/kafka-server-start.sh ./config/server.properties
後臺啟動
./bin/kafka-server-start.sh ./config/server.properties 1>/dev/null 2>&1 &2、topic消費
消費者啟動 ./kafka-console-consumer.sh --bootstrap-server 10.1.90.29:9092 --topic test --from-beginning 提供者啟動 ./kafka-console-producer.sh --broker-list localhost:9092 --topic test
持續更新中
問題1：
^[[A[2018-09-28 15:52:55,577] WARN [Consumer clientId=consumer-1, groupId=console-consumer-7862] Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)
這種問題是因為kafka配置的問題，配置文件的ip，比如你配置的10.1.90.29 ,但是你卻使用的localhost啟動，就是有問題，一直報警告。
問題2：
報錯：
zookeeper is not a recognized option
啟動
./kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
新版本並不是用這個的了，zookeeper選項沒有了，是用上面寫的命令。kafka 新版本命令 以及遇到問題匯總