flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Karthik Deivasigamani <karthi...@gmail.com>
Subject flink kafka consumer lag
Date Sun, 09 Jul 2017 06:16:22 GMT
   I'm using Flink 1.2.1 and FlinkKafkaConsumer09 to read data from
Kafka Server ( My consumer is able to read and everything
works fine.
But when I use the kafka_consumer_groups.sh command to find the lag
metrics it does not return the lag. Upon reading online I found that
Flink Kafka Consumer uses the low level API and manages the assignment
of partition itself.

What is the best way to monitor my flink kafka consumer's lag? Does
Flink expose the lag metrics per partition somewhere?


View raw message