kakfa如何查詢指定消費組lag

問題來源 實際項目中，我們會遇到kafka消費不及時，系統發現最新的數據一致無法出現，這時候通過其他kafka工具發現原來指定的消費組lag太大，也就是我們系統要麼出問題，要麼需要啓動更多的實例加快消費消息。每次通過kafka工具去查詢lag基本都是手工而且耗時且慢，能否在自己的系統中集成查詢指定消費組lag的功能，然後出現問題是可以管理界面中迅速查看lag呢？答案是當然可以。 kafka提供了這

>>阅读原文<<