kafka 手动维护offset，消费新topic 数据消费不了历史数据

自动提交管理后，kafka不会维护该消费者组对应topic的offset 消费者组消费新的topic数据的时候默认从endoffset开始，不会消费历史数据，消费历史数据需要配置 “auto.offset.reset”=“earliest” // kafka消费者配置 var kafkaParam = collection.mutable.Map( “bootstrap.servers” -> b

>>阅读原文<<