3、刪除 license、notice 、site-docs
4、進入bin目錄:cd bin
5、啟動:
①.啟動zookeeper:
nohup ./zookeeper-server-start.sh ../config/zookeeper.properties &
②.啟動kafka:
nohup ./kafka-server-start.sh ../config/server-2.properties &
6、建立topic
./kafka-topics.sh --create --zookeeper icloud_143:2181 --replication-factor 1 --partitions 1 --topic test
7、檢視topic
①檢視所有topic
./kafka-topics.sh --list --zookeeper zhangqi:2181
②檢視當前建立的topic描述
./kafka-topics.sh --describe --zookeeper localhost:2181 --topic my-replicated-topic
8、啟動生產者(控制台)
./kafka-console-producer.sh --broker-list zhangqi:9092 --topic test
9、啟動消費者(控制台)
./kafka-console-consumer.sh --bootstrap-server zhangqi:9092 --topic test
10、在生產者控制台輸入字串,可以看到消費者控制台進行消費並列印。
11、也可以一次性消費之前所有的訊息:
./kafka-console-consumer.sh --bootstrap-server zhangqi:9092 --topic test --from-beginning
Kafka單機多節點部署
基於kafka單機單節點部署,講config目錄下的server.properties檔案複製兩份,分別為 server 1.properties server 2.properties cp config server.properties config server 1.properties c...
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單機部署
2 解壓 tar zxvf kafka 2.12 0.11.0.3.tgz c local sda kafka3 使用kafka自帶的zookeeper,修改zookeeper.properties cd local sda kafka kafka 2.12 0.11.0.3 進入kafka主目錄 ...