Re: Why FlinkKafkaConsumer08 does not support exactly once or at least once semantic?

Hi Stefan, I didn`t notice that in the webpage.. Thanks a lot for your help! That makes me understand the delivery guarantees more clearly. Best Henry > 在 2018年9月20日，下午5:02，Stefan Richter > 写道： > > Hi, > > I think this part of the

Re: Why FlinkKafkaConsumer08 does not support exactly once or at least once semantic?

Hi, I think this part of the documentation is talking about KafkaProducer, and you are reading in the source code of KafkaConsumer. Best, Stefan > Am 20.09.2018 um 10:48 schrieb 徐涛 : > > Hi All, > In document of Flink 1.6, it says that "Before 0.9 Kafka did not > provide any mechanisms

Why FlinkKafkaConsumer08 does not support exactly once or at least once semantic?

Hi All, In document of Flink 1.6, it says that "Before 0.9 Kafka did not provide any mechanisms to guarantee at-least-once or exactly-once semantics” I read the source code of FlinkKafkaConsumer08, and the comment says: “Please note that Flink snapshots the offsets internally as