Flink Kafka from Time Offset

Posted by simon peyer on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-Kafka-from-Time-Offset-tp7261.html

Hi together

I'm using flink 1.0.1 and a FlinkKafkaConsumer09.

I'm very interested in getting data from a specific Time offset in Kafka.

Is there a property which can do this?

Or is there another way of handling such issues?

I'm also using checkpointing.

If I deploy a new pipeline with the same id's on the nodes, will the checkpoint be atomatically loaded and the state restored?

-Thanks

Simon