??????????flink job ????????kafka source function ????????offset

[jasonwu]

??????
????????????????????????checkpoint disable????????????????auto.commit 
??????????interval??????????offsets, ??????flink job sink 
??????????????offset?? 
????????????flinkKafkaConsumer??????????????????????????????????????????????????????????????
 ???????????????????????? ??????  ????????????????????????


53??????new ????kafkaConsumer??????????commitSync()??????????????

KafkaConsumer<?, ?&gt; kafkaConsumer = new KafkaConsumer(properties);
kafkaConsumer.commitSync();