1.功能实现
提供了一种sparkstreaming接收kafka消息的元数据恢复的功能，方便解决一些应用宕机后的重复消费问题，即宕机后重启，sparkstreaming可以从之前消费位置开始消费，而不是从头开始消费。提供了一种sparkstreaming接收kafka消息的元数
阅读背景：
kafka（十四）：SparkStreaming和Kafka接口的HA：checkpoints
来源：互联网
分享到：
