kafka自動提交位移全解析

kafka裏面有兩個參數 props.put("enable.auto.commit", "true"); props.put("auto.commit.interval.ms", "2000"); 其中第二個參數是自動提交位移時間，很多文檔講的不清楚，把這個自動提交位移翻譯成每隔 幾秒自動提交一次，這個完全是錯誤的。 直接看pool的代碼 裏面看更新源信息的方法 看第一個方法   找到源碼 把當

>>阅读原文<<