你是说emit之后的offset commit么?可以看下 `Kafka09Fetcher`的runFetchLoop方法
在2020年07月29日 15:09,shuwen zhou<jaco...@gmail.com> 写道: 比如读到一条offset值为100的消息,有Kafka Consumer source,一个Process算子和一个Sink算子 那么在这条消息到达Process算子,还未到达Sink算子时,提交offset是100吗? On Wed, 29 Jul 2020 at 14:51, venn <wxchunj...@163.com> wrote: checkpoint成功时就会把它的offset提交,可以看下这个类: FlinkKafkaConsumerBase 的 这个方法: notifyCheckpointComplete -----Original Message----- From: user-zh-return-5976-wxchunjhyy=163....@flink.apache.org <user-zh-return-5976-wxchunjhyy=163....@flink.apache.org> On Behalf Of shuwen zhou Sent: 2020年7月29日 14:24 To: user-zh@flink.apache.org Subject: Flink使用Kafka作为source时checkpoint成功提交offset的机制 大家好,请教一个问题, 当Flink在使用Kafka作为source,并且checkpoint开启时,提交的offset是在消息被链路最后一个算子处理之后才会把这条offset提交吗? 还是说这个消息只要从Kafka source读取后,不论链路处理到哪个算子, checkpoint成功时就会把它的offset提交呢? 另外有大神指路这段代码具体在哪个文件吗? 谢谢! -- Best Wishes, Shuwen Zhou -- Best Wishes, Shuwen Zhou <http://www.linkedin.com/pub/shuwen-zhou/57/55b/599/>