文章目錄
- 一、啟動
- 1.啟動Zookeeper（zk）
- 2.啟動Kafka
- 二、生產與消費
- 1.創建topic
- 2.生產訊息
- 3.消費訊息
- 總結
提示：這里Kafka的版本是kafka_2.12-2.7.0，因Kafka沒有提供version的命令，要查看版本可以進入到kafka/libs/目錄下，可以看到像kafka_2.12-2.7.0.jar這樣的檔案，其中2.12是Scala版本，2.7.0是Kafka版本，
一、啟動
下面啟動命令都是在Kafka根目錄下執行
cd /home/kafka/
1.啟動Zookeeper（zk）
因為Kafka依賴于zk所以先啟動zk
這里沒有單獨安裝過zk用的是kafka/bin目錄下自帶的
nohup ./bin/zookeeper-server-start.sh ./config/zookeeper.properties &
成功會回傳行程號
也可以通過埠號查看狀態
netstat -tunlp | grep 2181
2.啟動Kafka
nohup ./bin/kafka-server-start.sh ./config/server.properties &
成功會回傳行程號
二、生產與消費
1.創建topic
創建topic并命名為mytopic
./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic mytopic
成功后會回傳：Created topic mytopic.
查看下創建的所有topic
./bin/kafka-topics.sh --list --zookeeper localhost:2181
2.生產訊息
./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mytopic
這里寫兩條訊息測驗下（Ctrl+c可以退出）
3.消費訊息
另開一個視窗來消費資訊
./bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mytopic --from-beginning
成功消費到
最后看看效果
總結
以上就是Linux下Kafka基本功能的實作，期待各位同僚對本文進行點評！
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/273685.html
標籤：其他