kafkatool 配置_kafka tools的使用
生活随笔
收集整理的這篇文章主要介紹了
kafkatool 配置_kafka tools的使用
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
項目中會使用kafka tools,主要看變更消息有沒有被監聽到
目錄
1、下載與配置
2、排查問題
1、下載與配置
配置連接:
配置字符類型:在Tools -->Settings --> Topics,將 Key 和 Message 均設置為String 保存。這樣是全局設置,對所有 Topic 均生效
選中topics下的一個partition,然后點擊data中的執行,查看message即可
2、排查問題
問題一:查看生產者是否發了消息
執行完動作后,然后點擊工具中的運行,然后根據日期倒敘顯示,就可以看到最新的消息里面是否有自己執行動作產生的消息,如果數據庫有變更,kafka中沒有生產者的消息,那就是監聽機制有問題,如果數據庫沒變更就是數據庫有問題
問題二:消息是否有堆積(生產者消息沒問題,最終結果沒有變化,那就是消費者出現問題,有可能是消息堆積)
根據問題一中的方法,可以拿到最新消息的offset,然后去服務器上查看最近一條消費的消息的offset,觀察2者之前偏移量的差距就可以看到有沒有堆積
此外,像mq是有后臺登錄的,是可以直接看到消息是否有堆積,kafka應該也有后臺,具體可以自己研究
總結
以上是生活随笔為你收集整理的kafkatool 配置_kafka tools的使用的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 为什么大众车怎么多?
- 下一篇: java中自造类是什么意思_JAVA问题