配置config檔案為:server.properties
指令碼在 kafka/bin路徑下
啟動kafka:
./kafka-server-start.sh ../config/server.properties 1>/dev/null 2>
&1 &
# kafka-server-start.sh
檢視已建立的topic列表:
./kafka-topics.sh --list --zookeeper localhost:2181
檢視對應topic的描述資訊:
./kafka-topics.sh --describe --zookeeper xx.x.***.***:2181 --topic ***xx.xx.***xx.*** # --zookeeper為zookeeperip, --topic為topic名稱
消費訊息:
./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic ***xx.xx.***xx.*** --from-beginning # 若沒有任何返回或沒有響應,則該topic中沒有資料內容;否則有
kafka 檢視待消費資料 kafka檢視消費資料
kafka檢視消費資料 一 如何檢視 在老版本中,使用kafka run class.sh 指令碼進行檢視。但是對於最新版本,kafka run class.sh 已經不能使用,必須使用另外乙個指令碼才行,它就是kafka consumer groups.sh 普通版檢視所有組 要想查詢消費資料,必...
kafka 檢視待消費資料 kafka檢視消費資料
一 如何檢視 在老版本中,使用kafka run class.sh 指令碼進行檢視。但是對於最新版本,kafka run class.sh 已經不能使用,必須使用另外乙個指令碼才行,它就是kafka consumer groups.sh 普通版檢視所有組 要想查詢消費資料,必須要指定組。那麼線上執行...
kafka檢視消費組未消費資料情況0 9之後版本
bin kafka topics.sh zookeeper 127.0.0.1 2181 list 檢視topic bin kafka consumer groups.sh new consumer bootstrap server localhost 9092 list 檢視消費組 bin kaf...