kafka安裝使用和遇到的坑
阿新 • • 發佈：2018-04-08
一個 star pic cnblogs cte 下載安裝 下載 .org pre
下載安裝
參考：https://segmentfault.com/a/1190000012730949
? https://kafka.apache.org/quickstart
關閉服務
關閉zookeeper bin/zookeeper-server-stop.sh
關閉kafka bin/kafka-server-stop.sh
遇到的坑
問題1
[2018-04-08 11:20:32,999] WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn) java.net.ConnectException: Connection refused at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:744) at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:361) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1141)
上面問題說明無法連接到zookeeper服務中，原因是沒有啟動zk，或者啟動zk後又關閉了
解決方法
1、單獨在一個linux終端運行bin/zookeeper-server-start.sh config/zookeeper.properties 啟動zk，再開一個linux終端啟動kakfa服務，然後再開一個linux終端創建topic
2、使用守護進程啟動zk和kafka
bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
bin/kafka-server-start.sh -daemon config/server.properties
kafka安裝使用和遇到的坑