(一)zookeeper
1.下載下傳zookeeper
下載下傳位址: http://apache.fayea.com/zookeeper/
我用的3.4.10版本的
2.解壓zookeeper
解壓後的目錄結構
3.配置zookeeper
進入 conf檔案夾下,有一個zoo_sample.cfg檔案,這是一個簡單的配置例子,我們需要将它改名為 zoo.cfg,我是複制重命名的,并且把帶#的注釋去了
4.啟動zookeeper
在bin目錄下
./zkServer.sh start
可以測試一下是否啟動成功
在bin目錄下
./zkCli.sh
ok , zookeeper的單機版已經部署成功了
(二)kafka
1.下載下傳kafka
下載下傳位址:http://apache.fayea.com/kafka/2.1.0/
2.解壓kafka
解壓後的根目錄結構如下
3.啟動kafka服務
在bin目錄下,啟動,指定根目錄config下的配置檔案,不要關閉該終端
./kafka-server-start.sh ../config/server.properties
4.建立topic
在bin目錄下
./kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
5.檢視topic
在bin目錄下
./kafka-topics.sh --list --zookeeper localhost:2181
6.産生消息,建立消息生産者
在bin目錄下
./kafka-console-producer.sh --broker-list localhost:9092 --topic test
7.消費消息,建立消息消費者,在生産者中發送的消息都會出現在消費者中
在bin目錄下
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
這樣本機的kafka環境就搭建好了