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
