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?