每次學一個東西從基礎的開始，循序漸進。

不急不躁，路還很長。

所有教程都是學習汪文君大神的kafka教程的。

一、部署

這裏選的kafka版本是 0.10.2.1 下載連接 https://download.csdn.net/download/lsl13551615708/9881118

0.這裏我是在自己虛擬機上安裝的，虛擬機的安裝可以搜一下。如果確實搜不到也不急的話可以留言。虛擬機安裝好後記得橋接網絡並掛載共享文件。

1.在/usr/local下創建如下路徑 /usr/local/kafka/demo ，執行kafka的安裝文件 tar -xzvf kafka_2.10-0.10.2.1 -c demo

2.在安裝後的路徑下創建同級目錄 data用於存放kafka和zk的數據信息

3.配置zk和kafka

進入安裝路徑下的config目錄，輸入命令vim zookeeper.properties

修改dataDir = /usr/local/kafka/demo/data/zk

clientPort=2181

:wq!保存後退出

輸入命令vim server.properties

修改

log.dirs=/usr/local/kafka/demo/data/kafka

zookeeper.connect=ip地址:2181

listeners=PLAINTEXT://ip地址:9092

二、啟動並測試

1.啟動zk

這裏用的是kafka自帶的zk，畢竟只是學習

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties

netstat -na|grep 2181 查看啟動是否成功

2.啟動kafka

bin/kafka-server-start.sh -daemon config/server.properties

netstat -na|grep 9092 查看是否啟動

tail -200f logs/server.log 查看是否報錯 如果這裏報什麽主機名不匹配的錯誤 那麽 配置hosts 你的ip 主機名

3.創建topic

bin/kafka-topics.sh --create --topic test --zookeeper localhost:2181 --partitons 1 --replication-factor 1 關於kafka的原理 和接口解釋可以瀏覽 https://blog.csdn.net/ychenfeng/article/details/74980531

創建成功會返回 created topic "test"

4.創建producer，並生產數據

bin/kafka-console-producer.sh --topic test --broker-list 192.168.31.187:9092 這裏的ip改成你的虛擬機ip

然後輸入你想生產的數據

5.創建consumer

另外起一個終端。

bin/kafka-console-consumer.sh --topic test --bootstrap-server 192.168.31.187:9092 這裏ip端口換成虛擬機ip端口

6.測試

在producer終端輸入任何信息按回車 consumer就可以收到消息。測試成功

一、最新Kafka單節點部署+測試 完整