kafka自动提交位移全解析

kafka里面有两个参数 props.put("enable.auto.commit", "true"); props.put("auto.commit.interval.ms", "2000"); 其中第二个参数是自动提交位移时间，很多文档讲的不清楚，把这个自动提交位移翻译成每隔 几秒自动提交一次，这个完全是错误的。 直接看pool的代码 里面看更新源信息的方法 看第一个方法   找到源码 把当

>>阅读原文<<