16.centos7上安裝kafka

單機版、 集羣版

效果：

1.單機版

參考：https://www.linuxidc.com/Linux/2017-01/139732.htm （消費者語法過老）

kafka生產者與消費者相關命令行

https://blog.csdn.net/wf3612581/article/details/81842574

1.1下載

http://kafka.apache.org/downloads

 

1.2 安裝

1.2.1 安裝jdk

https://my.oschina.net/springMVCAndspring/blog/1601197

1.2.2 安裝kafka

(1) 上傳到Linux服務器上

（2） 解壓到合適的位置

（3）修改解壓文件名稱

 

（4）進入解壓目錄 後臺啓動zookeeper服務

./zookeeper-server-start.sh ../config/zookeeper.properties &

（5） 啓動kafka服務

./kafka-server-start.sh ../config/server.properties &

 

 

查看：ps -ef | grep kafka

1.3 檢驗

1.3.1.建立一個叫"test1234"的topic，它只有一個分區，一個副本：

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

用list查看建立的topic

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

1.3.2 從新打開一個窗口 做爲消費者

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1234
 

1.3.3 生產者窗口

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

1.4 重啓電腦後 啓動服務的步驟

(1) 啓動zookeeper

./zookeeper-server-start.sh ../config/zookeeper.properties &

(2) 啓動kafka服務

./kafka-server-start.sh ../config/server.properties &

用list查看建立的topic

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

(3) 新打開一個窗口 啓動消費者

./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test1234

(4) 啓動生產者  發生消息

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

（5）效果

1.5 簡單整合springboot

注意：Linux上的kafka要想被訪問到 還須要 修改配置文件

搭建項目

生產者 消費者   參考：http://www.javashuo.com/article/p-knhajowl-bx.html

修改的地方是：

1.6 附 軟件及代碼

連接：https://pan.baidu.com/s/1zhbepbSKHuuDtnY9Z5DiKw  提取碼：8c59