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