各位大佬有问题请教
flink 如果开启了checkpoint,是把消费kafka offset存放在在state,checkpointing到后端保存，同时会把offset回传到kafka,在kafka consumer_topic里保存 用户groupid的offset,正常情况下这是一个bakup 现在比如我开启了checkpoint，运行了一段时间后，我手动重启任务，这个时间没有用-s 去指定chkpoint/savepoint， 那么这种情况下，flink由于没获取state里的offset,它是重新按配置kafka的lastest/earliestj里去消费了？ 还是会自动去找kafka里consumer_topic保存的topic消费？*来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
对的是我！不是savepoint恢复任务的话，flink-kafka-connector会按照配置的消费策略来确定 Kafka 分区的起始位置。*来自志愿者整理的flink邮件归档
2021-12-08 17:02:50赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
问答排行榜
最热
最新
推荐问答
