在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/
Locked
