kafka本地部署

zookeeper安裝

zookeeper安裝位址

kafka安裝

kafka安裝位址

版本對應關係

kafka

zookeeper

kafka_2.12-2.4.0

apache-zookeeper-3.6.0-bin

zookeeper和kafka的版本不對應好像是會出問題

使用zookeeper集群

.

/zkserver.sh start

.

/zkserver.sh status /
/ 檢視zookeeper啟動狀態
./zkcli.sh			/
/ 進入zookeeper客戶端

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

bin/zookeeper-server-stop.sh config/zookeeper.properties

bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 1 --topic firsttopic

bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --describe --topic firsttopic

bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --delete --topic firsttopic

bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic firsttopic

bin/kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic firsttopic --

from
-beginning

Kafka 單機kafka部署

1 上傳部署包 kafka 2.11 0.11.0.0.tgz 放到 opt software 2 解壓 tar zxvf kafka 2.11 0.11.0.0.tgz c opt module 3 切換目錄 opt module kafka 2.11 0.11.0.0 conf 4 修改配置 v...

部署 kafka 大資料Kafka集群部署

2 kafka集群部署 1 解壓安裝包 atguigu hadoop102 software tar zxvf kafka 2.11 0.11.0.0.tgz c opt module 2 修改解壓後的檔名稱 atguigu hadoop102 module mv kafka 2.11 0.11.0...

kafka本地除錯

主要本地除錯命令 nohup bin kafka server start.sh config server.properties bin kafka server stop.sh bin kafka topics.sh create zookeeper localhost 2181 replica...