項目中會使用kafka tools，主要看變更消息有沒有被監聽到
目錄
1、下載與配置
2、排查問題
1、下載與配置
完成下載安裝http://www.kafkatool.com/download.html
配置連接：
配置字符類型：在Tools -->Settings --> Topics，將 Key 和 Message 均設置為String 保存。這樣是全局設置，對所有 Topic 均生效
選中topics下的一個partition，然后點擊data中的執行，查看message即可
2、排查問題
問題一：查看生產者是否發了消息
執行完動作后，然后點擊工具中的運行，然后根據日期倒敘顯示，就可以看到最新的消息里面是否有自己執行動作產生的消息，如果數據庫有變更，kafka中沒有生產者的消息，那就是監聽機制有問題，如果數據庫沒變更就是數據庫有問題
問題二：消息是否有堆積（生產者消息沒問題，最終結果沒有變化，那就是消費者出現問題，有可能是消息堆積）
根據問題一中的方法，可以拿到最新消息的offset，然后去服務器上查看最近一條消費的消息的offset，觀察2者之前偏移量的差距就可以看到有沒有堆積
此外，像mq是有后台登錄的，是可以直接看到消息是否有堆積，kafka應該也有后台，具體可以自己研究
本文中圖片使用https://blog.csdn.net/Dongguabai/article/details/86526299完成，如有侵權，請聯系刪除