Replays message in Kafka topics with FlinkKafkaConsumer09

[Jack Huang]

Hi all,

I am trying to force my job to reprocess old messages in my Kafka topics
but couldn't get it to work. Here is my FlinkKafkaConsumer09 setup:

val kafkaProp = new Properties()
kafkaProp.setProperty("bootstrap.servers", "localhost:6667")
kafkaProp.setProperty("auto.offset.reset", "earliest")

env.addSource(new FlinkKafkaConsumer09[String](input, new
SimpleStringSchema, kafkaProp))
    .print

​

I thought *auto.offset.reset* is going to do the trick. What am I missing
here?


Thanks,

Jack Huang