?????????? flink ??????????checkpoint,????????kafka 
offset????????state,checkpointing????????????????????offset??????kafka,??kafka 
consumer_topic??????
????groupid??offset,??????????????????bakup


????????????????checkpoint??????????????????????????????????????????????????-s 
??????chkpoint/savepoint??
????????????????flink??????????state????offset,??????????????kafka??lastest/earliestj????????????
 ??????????????kafka??consumer_topic??????topic??????


??????

回复