回复：修改topic名称后从Savepoint重启会怎么消费Kafka

Tue, 01 Dec 2020 22:03:19 -0800 

hi，实时上并不是你说的这样，从sp重启时因为存在RestoreState，而且Topic名称被修改，会导致restoredState内找不到新的KafkaTopicPartition
新的消费位置会置为EARLIEST_OFFSET


if (restoredState != null) {
   for (KafkaTopicPartition partition : allPartitions) {
      if (!restoredState.containsKey(partition)) {
         restoredState.put(partition, 
KafkaTopicPartitionStateSentinel.EARLIEST_OFFSET);
      }
   }




------------------------------------------------------------------
发件人：熊云昆 <xiongyun...@163.com>
发送时间：2020年12月1日(星期二) 22:57
收件人：user-zh <user-zh@flink.apache.org>; Shuai Xia <jkill...@dingtalk.com>
主　题：Re:修改topic名称后从Savepoint重启会怎么消费Kafka


可以手动控制的，如果不设置默认是从最新位置开始消费，否则按照你的startup-mode来





在 2020-12-01 20:59:48，"Shuai Xia" <jkill...@dingtalk.com.INVALID> 写道：
>
>Hi，大佬们
>突然有一个疑问点，Flink消费kafka的Job保存了SP之后停止，修改代码中的topic名称之后重启。
>会从新topic的哪里开始消费？与startup-mode一致，还是从最新呢？
>可以手动控制么？

回复