Re: Reading messages from start - new job submission

Hi , I'm using 1.7.0 Cheers -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: Reading messages from start - new job submission

Thanks for the answer, But my question is why do I need to set /myConsumer.setStartFromEarliest();/ if I set this property /setProperty("auto.offset.reset", "earliest") /in consumer properties ? I want the consumer to start reading from earliest only If offsets could not be found as stated in th