Kafka單機單節點部署


1、下載地址:
https://mirrors.bfsu.edu.cn/apache/kafka/2.5.0/kafka_2.13-2.5.0.tgz

2、下載后,解壓:tar -zxvf kafkaxxxxxx.tgz

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


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM