kafka 数据容错之 zookeeper保存 spark消费的

https://www.iteblog.com/archives/1381.html

调用 KafkaCluster 类的 setConsumerOffsets 方法 去更新 Zookeeper 里面的信息