kafka 手動維護offset，消費新topic 數據消費不了歷史數據

自動提交管理後，kafka不會維護該消費者組對應topic的offset 消費者組消費新的topic數據的時候默認從endoffset開始，不會消費歷史數據，消費歷史數據需要配置 「auto.offset.reset」=「earliest」 // kafka消費者配置 var kafkaParam = collection.mutable.Map( 「bootstrap.servers」 -> b

>>阅读原文<<