flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From simon peyer <simon.pe...@soom-it.ch>
Subject Flink Kafka from Time Offset
Date Mon, 30 May 2016 11:45:54 GMT
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?

View raw message