Kafka單機單節點部署

2022-03-18 23:09:17 字數 954 閱讀 7126

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主目錄 ...