????????????????????????
????flink??flink??kafka??kafka??????????????????????????????????????flink??????????????kafkaconsumer ??kafkaproducer??????????flink??????????????kafka offset??group.id??????????????????group.id????????????????????kafka??api ????????????????flink??????????application????????????????????????????????????????group?????????????????????? ??????????????????flink????kafka consumer??APi???????? assign() ???????????? kafka ????????????subscribe() ??????????????group.id ????kafka consumer ?????????????????????????????????????????????????????????????? Best, Shengjk1 ??2019??03??27?? 14:24??????<[email protected]????<[email protected]>> ?????? ????????????????checkpoint??flink??????????kafka offset????????????????flink?????????????????????? PS????????????????kafkfa source????????group.id??flink??????????application????????????????????????????????????????group???????????????????????? ------------------ ???????? ------------------ ??????: "????????????"<[email protected]>; ????????: 2019??3??27??(??????) ????1:42 ??????: "user-zh"<[email protected]>; ????: ?????? flink savepoints ?? checkpoints?????? ????????~ ------------------ ???????? ------------------ ??????: "shengjk1"<[email protected]>; ????????: 2019??3??27??(??????) ????12:10 ??????: "[email protected]"<[email protected]>; ????: "user-zh"<[email protected]>; ????: ?????? flink savepoints ?? checkpoints?????? ??????flink-connector-kafka????kafka 0.8????????????????????????zk????????????????????kafka??(??????kafka??????API) ????Flink????????????????????offset????????????????????checkpoint?? ??????????checkpoint????????kafka??????API????offset?????? ??????????checkpoint??flink????????checkpoint????????offset????????????state backends??????????????kafka consumer??????Api??????kafka ???????????? https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/connectors/kafka.html Best, Shengjk1 ??2019??03??27?? 11:52??????<[email protected]> ?????? ??????????????????checkpoint??savepoint???????????????????????????????????????????????????????????????????????????????????? ???????????????????? 1??flink ???? kafka??kafka??offset????flink??????????????????????????????????zookeeper???? PS??????zookeeper??????????offset???????????????????????????????? 2????????????????????????????????????????????????????flink??????????????offset????????????zookeeper?? ------------------ ???????? ------------------ ??????: "[email protected]"<[email protected]>; ????????: 2019??3??27??(??????) ????11:38 ??????: "user-zh"<[email protected]>; ????: ????: ?????? flink savepoints ?? checkpoints?????? ???????????????????? savepoint ??????????????????????????????????????????????????savepoints???????????????????????????????????????????????????????????????????????????????????????????? [email protected] ???????? ???? ?????????? 2019-03-27 11:03 ???????? user-zh ?????? ?????? flink savepoints ?? checkpoints?????? ??????savepoint????????????????????????????????????????????????????????????savepoints???? ------------------ ???????? ------------------ ??????: "[email protected]"<[email protected]>; ????????: 2019??3??27??(??????) ????11:01 ??????: "user-zh"<[email protected]>; ????: ????: flink savepoints ?? checkpoints?????? checkpoints: ????????????????????????????????????????????checkpoint?????????????????????????????????????????????????????????????????????????????? savepoints?? ????????????????????????????????????????????????????????????savepoints????????????????????????????????????????savepoints????????????????????????????????????????????????????savepoints????????????????????????????????????savepoints???????????????? [email protected] ???????? ???? ?????????? 2019-03-27 10:48 ???????? user-zh ?????? flink savepoints ?? checkpoints?????? ??????????flink savepoints ?? checkpoints????????????????????checkpoints??????????????????savepoints????????????????????????????????????????????????????savepoints??????????????savepoints?? PS??????????????checkpoints, 3s??????????cancel??????????????????-s??????savepoints????????????????????????????savepoints????????????checkpoints????????????????????????????
