????savepoint??????????????flink-kafka-connector?????????????????????????? 
Kafka 
????????????????https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/dev/connectors/kafka.html


| |
??????
|
|
[email protected]
|
??????????????????????
??2021??1??16?? 19:38??????<[email protected]> ??????
??????????&nbsp;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??????


??????

回复