Hi Dominique,
have you tried setting the Kafka property props.put("auto.offset.reset",
"smallest");?Cheers, Till On Thu, Mar 17, 2016 at 1:39 PM, Dominique Rondé < dominique.ro...@codecentric.de> wrote: > Hi folks, > > i have a kafka topic with messages from the last 7 days. Now i have a new > flink streaming process and like to consume the messages from the > beginning. If I just bring up the topology, the consumer starts from this > moment and not from beginning. > > THX > > Dominique >
