2、新建zookeeper和kafka資料夾目錄，在zookeeper目錄新建zkdata、zkdatalog目錄，在kafka目錄新建kafkalogs目錄。將1步驟中解壓後的兩個資料夾分別放入zookeeper和kafka目錄。
3、進入zookeeper的conf目錄，將zoo_sample.cfg複製乙份zoo.cfg，修改zoo.cfg：
datadir=/home/gaofeng/zookeeper/zkdata
datalogdir=/home/gaofeng/zookeeper/zkdatalog
4、進入kafka的config目錄，修改server.properties檔案。
log.dirs=/home/gaofeng/kafka/kafkalogs
5、啟動zookeeper，如果無報錯則說明啟動成功。
./bin/zkserver.sh start
6、檢視zookeeper是否啟動成功
./bin/zkserver.sh status
7、啟動kafka
./bin/kafka-server-start.sh -daemon config/server.properties
8、我們可以使用jps終端命令檢視是否啟動（quorumpeermain是zookeeper服務）：
[root@bogon kafka_2.12-1.1.0]# jps
4384 kafka
3921 quorumpeermain
4412 jps
9、使用kafka
1）、建立topic：
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
2）、檢視topic：
./bin/kafka-topics.sh --list --zookeeper localhost:2181
3）、生產者
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
4）、消費者
./bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning
5）、刪除topic
./bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic test
備註：[server.properties需要 設定delete.topic.enable=true]
sudo ifconfig enp2s0 10.102.7.165 netmask 255.255.255.0
'); (window.slotbydup = window.slotbydup || ).push(); })();
'); (window.slotbydup = window.slotbydup || ).push(); })();
Kafka安裝配置
kafka執行依賴 zookeeper，如未安裝zookeeper請參考 zookeeper安裝使用 kafka版本問題 這又是一大坑 如果你的storm安裝的是1.0.x系列或更低的版本，建議你安裝0.8.x.x版本的kafka。如果你的storm安裝的是1.1.x系列或更高的版本，建議你安裝0....
kafka安裝配置
一.zookeeper部署 tar xvf zookeeper 3.4.6.tar.gz mv zookeeper 3.4.6 zookeeper chown r root root zookeeper 2.修改配置 cd zookeeper conf cp zoo sample.cfg zoo.c...
kafka安裝配置
1 部署規劃 作業系統 centos 7.2 kafka版本 kafka 2.10 0.8.2.1 安裝路徑 opt kafka 2.10 0.8.2.1 節點 192.168.20.100 105 2 部署過程 2.2 解壓 tar zxvf kafka 2.10 0.8.2.1.tgz 2.3 ...