sparkstreaming中kafka的offset提交

就kafka而言，offset提交方式有兩種，自動和手動。 將enable.auto.commit設置爲true，即可自動提交 props.put("enable.auto.commit", "true"); props.put("auto.commit.interval.ms", "1000"); 或者採用commitAsync來自動提交。 sparkstreaming消費kafka數據，提交方

>>阅读原文<<