1 开启checkpoint时：

我们需要在数据流创建的时候设置开启自动提交offst至checkpoint，它会自动同步offset到kafka

这样设置之后，程序在checkpoint时，如果checkpoint成功， 那么会同步当前checkpoint中的offset至kafka

2 关闭checkpoint时:

1、如果还想自动提交offset

可以在kafka的prop中设置

2、如果是自动管理offst

你需要自己设置offset的保存位置(redis,zookeeper,mysql)等，然后设置获取offset