Hi Tony, Thanks for the report. At first glance of the description, what you described doesn’t seem to match the expected behavior. I’ll spend some time later today to check this out.
Cheers, Gordon On 15 November 2017 at 5:08:34 PM, Tony Wei (tony19920...@gmail.com) wrote: Hi Gordon, When I used FlinkKafkaConsumer010 to consume log from Kafka, I found that if I used `setStartFromLatest()` the kafka consumer api didn't auto commit offsets back to consumer group, but if I used `setStartFromGroupOffsets()` it worked fine. I am sure that the configuration for Kafka has `auto.commit.interval.ms = 5000` and `enable.auto.commit = true` and I didn't enable checkpointing. All the difference is only the change from `setStartFromGroupOffsets()` to `setStartFromLatest()`, but the auto commit mechanism just stopped working. My Flink cluster version is 1.3.2. My Kafka cluster version is 0.10.2.1. My Zookeeper version for Kafka is 3.4.6-1569965, built on 02/20/2014 09:09 GMT. My Kafka connector library is "org.apache.flink" % "flink-connector-kafka-0.10_2.10" % "1.3.2" Thanks for your help in advance. Best Regards, Tony Wei
