Hi, I am not getting anything in the metric "flink.operator.KafkaConsumer.records-lag-max". Tried checking the value of Mbean using JMX for "org.apache.flink.taskmanager.job.task.operator.KafkaConsumer.records-lag-max" but I am always getting either NaN or 0.
I have checked other Mbeans such as "org.apache.flink.taskmanager.job.task.operator.KafkaConsumer.records-lead-min", "org.apache.flink.taskmanager.job.task.operator.KafkaConsumer.records-consumed-rate" and I am getting some value. Has anyone faced any issue with the Kafka consumer metric: "records-lag-max"? Flink Version: 1.13.1 Kafka Client Version : 2.2.1-cdh6.3.2