kafka安裝評測
下載地址：http://archive.apache.org/dist/kafka/2.0.0/
可以直接通過wget下載
依賴jdk環境

可以安裝在/usr/local中
vim server.properties
修改對外的IP地址，否則kafka在別的機器上無法釋出和訂閱
advertised.listeners=PLAINTEXT://192.168.80.129:9092

開啟監聽服務：listeners=PLAINTEXT://localhost:9092
(1)必須先啟動zookeeper ,可以安裝外部的，也可以通過kafka自帶的執行
nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
(2)啟動kafka
nohup bin/kafka-server-start.sh config/server.properties &
(3)建立topic
bin/kafka-topics.sh --create --zookeeper 192.168.80.129:2181 --replication-factor 1 --partitions 1 --topic test
建立一個名為test的topic，只有一個副本，一個分割槽。
通過list命令檢視剛剛建立的topic
bin/kafka-topics.sh -list -zookeeper 192.168.80.129:2181
(4)啟動producer併發送訊息啟動producer
bin/kafka-console-producer.sh --broker-list 192.168.80.129:9092 --topic test
(5)啟動consumer
bin/kafka-console-consumer.sh --bootstrap-server 192.168.80.129:9092 --topic test --from-beginning

看了很多例子，發現使用--zookeeper命令就報錯，後來查了官網給的例子，使用的是--bootstrap-server了
(注意，此處區分zookeeper埠2181，kafka埠9092)