kafka在mac上的安裝與啟用
阿新 • • 發佈:2018-12-24
1.kafka安裝包下載
在Apache的kafka官網下載安裝包,以下4個包隨便選一個下載。
2.啟動zookeeper的服務
進入檔案的解壓目錄,輸入
bin/zookeeper-server-start.sh config/zookeeper.properties
3.啟動kafka的服務
另起一個視窗,進入解壓目錄,輸入
bin/kafka-server-start.sh config/server.properties
4.配置topic
另起視窗,進入解壓目錄,輸入
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic my_test
我們也可以通過以下命令檢視topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
到這裡topic就建立完成了
5.建立生產者
輸入以下命令可成功建立生產者
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic my_test
6.建立消費者
另起視窗,輸入以下命令:
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my_test --from-beginning
這樣消費者也建立成功了
我們可以在生產者的視窗中輸入一個1,可以發現消費者中也會出現一個1
到這裡,單點的kafka環境部署就全部結束了!