Hi,

I am currently facing strange behaviour of the FlinkKafkaConsumer09 class. I am using Flink 1.0.3.

These are my properties:

val properties = new Properties()
properties.setProperty("bootstrap.servers", config.urlKafka)
properties.setProperty("group.id", COLLECTOR_NAME)
properties.setProperty("auto.offset.reset", *"earliest"*)

According to the new consumer API of Kafka, this should result in the following:

/auto.offset.reset: * smallest : automatically reset the offset to the smallest offset/ (source: https://kafka.apache.org/documentation.html#newconsumerapi)

However, it starts from the latest item in my topic. Is this a bug or am I doing something wrong?

Regards,
Kevin

Reply via email to