group.id更改,通过savepoint启动的Flink任务,Kafka consumer是否仍然可以获取到保存在状态中的start position?

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

group.id更改,通过savepoint启动的Flink任务,Kafka consumer是否仍然可以获取到保存在状态中的start position?

justskinny
Hi,all    根据文档,如果从checkpoint或者savepoint中恢复任务,则Kafka Consumer会使用状态中的start position。    https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/connectors/kafka.html#kafka-consumers-start-position-configuration    请问通过savepoint恢复的任务,如果group.id更改,Kafka consumer是否仍然可以获取到保存在状态中的start position?