我使用FlinkKafkaConsumer来使用kafka并启用检查点。现在,我对偏移量管理和检查点机制有些困惑。
我已经知道flink将开始从消费者组的分区中读取分区。
https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#kafka-consumers-start-position-configuration
偏移量将存储到远程fileSystem中的检查点中。
https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#kafka-consumers-and-fault-tolerance
如果我通过执行yarn application -kill appid
来停止应用程序会发生什么
并运行./bin flink run ...
之类的启动命令?
flink将获得检查点或kafka管理的group-id的偏移量吗?