kafka已生產消息,消費記錄查看


在測試過程中有用到kafka,由於開發說我往kafka里面生產了消息,通知了對方要消費。。。。看到這塊一頭霧水

kafka主要2個功能生產和消費

##查詢topic列表

./kafka-topics.sh --list --zookeeper localhost:21810

###模擬生產數據
./kafka-console-producer.sh --broker-list 10.12.70.18:9092,10.12.70.19:9092,10.12.70.20:9092 --topic partner_supplier
##模擬消費數據
./kafka-console-consumer.sh --bootstrap-server 10.12.70.18:9092,10.12.70.19:9092,10.12.70.20:9092 --from-beginning --topic partner_supplier

 

上面生產和消費有點類似qq2個客戶端發消息

具體開發說我發了kafka消息,你看下kafka里面有木有我發的消息

具體步驟

1.向開發獲取topic名稱

2.查詢topic列表看下是否有這個topic名稱

3.進行模擬消費,然后列出一堆已生產的數據。看下是否有相關數據

==========================================================

kafka消息消費記錄,由於實際應用該變更的記錄沒有變更,先要看kafka消息是否有被消費;如果記錄被消費掉的話通過上面的查詢也很難定位問題;

./kafka-consumer-groups.sh  --bootstrap-server 10.12.70.18:9092,10.12.70.19:9092,10.12.70.20:9092  --list   #查詢group列表

./kafka-consumer-groups.sh --bootstrap-server 10.1.202.9:8097  --describe --group XXX-log-group    #查詢指定group消費記錄,以此判斷到底程序是否有消費掉消息從而定位問題。

 


免責聲明!

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



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