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/kafka-consumer-groups.sh --new-consumer --bootstrap-server localhost:9092 --describe --group daemon //檢視消費情況
group : 消費者組
topic : topic的名字
pid : partition的id
offset : kafka消費者在對應分割槽上已經消費的訊息數【位置】
logsize : 已經寫到該分割槽的訊息數【位置】
lag : 還有多少訊息未讀取（lag = logsize - offset）
owner : 分割槽建立在哪個broker
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消費之kafka檢視topic是否有資料
配置config檔案為 server.properties 指令碼在 kafka bin路徑下 啟動kafka kafka server start.sh config server.properties 1 dev null 2 1 kafka server start.sh檢視已建立的topic...