Sorry all, it seems bad formatting in my email message, now I send it again gently and hope it work.
I would like to start a discussion about FLIP-XXX: SupportcurrentFetchEventTimeLag and processingLag metrics [1]. The main motivation for this change was that I had some difficulties inimplementing the currentFetchEventTimeLag metrics for KafkaSource [2]. So I proposed to let the SourceReaderMetricGroup provide an interface to capturethe FetchTime so that all the FLIP-27 [3] sources can easily implement thecurrentFetchEventTimeLag metrics. In addition, I propose to support the processingLag metric for the FLIP-27sources to measure the current processing latency of the source. See the FLIP [1] and Jira [2] for more details. Looking forward to your comments and opinions! Thanks, TanJiaLiang. [1] https://docs.google.com/document/d/1nPhh1A-v-a7zyQyl1A5-K5DeUqbfxNXdjr2TVBT-QMs/edit?usp=sharing [2] https://issues.apache.org/jira/browse/FLINK-33173 [3] https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface >
