在flink 1.11.0中任务未开启checkpoint时，消费kafka，已开启autocommit，kafka端可以正常查看lag，但这时候从flink web ui的metric中可以看到current offset，但是commite offset一直是Long的最小值 有以下两个问题，还请大佬们赐教 1、“这时候从flink web ui的metric中可以看到current offset，但是commite offset一直是Long的最小值”，这种是正常的吗？是否是少了什么配置，还是flink的bug？只从flink任务的这些metric应该是计算不出来lag的 2、观察到flink web ui 的metric中有两个lag相关， 0.Source__TableSourceScan(table=[[default_catalog__default_database__odeon_test_li.KafkaConsumer.records-lag-max 和 0.Source__TableSourceScan(table=[[default_catalog__default_database__odeon_test_li.records-lag-max 这两个lag的含义是什么？是否是flink任务消费kafka的延迟？没有找到相关文档。
-- Sent from: http://apache-flink.147419.n8.nabble.com/
