关于 earliest 的疑问

来源：11-9 Flink对接Kafka数据分析结果入Redis

小欧的哈士奇

2021-12-05

老师，请问一下，既然已经配置了 auto.offset.reset=earliest，重启的时候也没有指定从checkpoint恢复数据，那为什么不是从头消费？而是只消费了最后几条数据？

写回答

1回答

Michael_PK

2021-12-06

earliest是从最早的，但是flink内部如果有chk的，他会自动记录到statebackend中的，如果没有设置chk，那就会从最早的来

Michael_PK

小欧的哈士奇

我知道你的意思了。出现异常了，在启动的时候可以手工传入指定的chk的路径，就能从挂掉的地方恢复。

2021-12-08

共2条回复

Flink+ClickHouse 玩转企业级实时大数据开发

已经在做大数据，Flink助力轻松提薪；尚未入行，让你弯道超车

1001 学习 · 225 问题

相似问题

回答 1

回答 1

回答 1

回答 1

回答 1