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

Reply via email to