flink??flink??kafka??kafka??flink??kafkaconsumer
??kafkaproducer??flink??kafka
offset??group.id??group.idkafka??api
flink??applicationgroup??
??flinkkafka consumer??APi assign()
kafka subscribe() ??group.id kafka consumer
??
Best,
Shengjk1
??2019??03??27?? 14:24??<1048095...@qq.com<1048095...@qq.com>> ??
checkpoint??flink??kafka
offsetflink??
PSkafkfa
sourcegroup.id??flink??applicationgroup
-- --
??: ""<1048095...@qq.com>;
: 2019??3??27??(??) 1:42
??: "user-zh";
: ?? flink savepoints ?? checkpoints??
~
-- ???? --
??: "shengjk1";
: 2019??3??27??(??) 12:10
??: "user-zh@flink.apache.org";
: "user-zh";
: ?? flink savepoints ?? checkpoints??
??flink-connector-kafkakafka
0.8zkkafka??(??kafka??API)
Flinkoffsetcheckpoint??
??checkpointkafka??APIoffset??
??checkpoint??flinkcheckpointoffsetstate
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??<1048095...@qq.com> ??
??checkpoint??savepoint
1??flink
kafka??kafka??offsetflink??zookeeper
PS??zookeeper??offset
2flink??offsetzookeeper??
-- --
??: "baiyg25...@hundsun.com";
: 2019??3??27??(??) 11:38
??: "user-zh";
: : ?? flink savepoints ?? checkpoints??
savepoint
??savepoints
baiyg25...@hundsun.com
?? 2019-03-27 11:03
user-zh
?? ?? flink savepoints ?? checkpoints??
??savepointsavepoints
-- --
??: "baiyg25...@hundsun.com";
: 2019??3??27??(??) 11:01
??: "user-zh";
: : flink savepoints ?? checkpoints??
checkpoints:
checkpoint??
savepoints??
savepointssavepointssavepointssavepoints
baiyg25...@hundsun.com
?? 2019-03-27 10:48
user-zh
?? flink savepoints ?? checkpoints??
??flink savepoints ??
checkpointscheckpoints??savepointssavepoints??savepoints??
PS??checkpoints,
3s??cancel??-s??savepointssavepointscheckpoints
