kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Robert Metzger <rmetz...@apache.org>
Subject Checking the consumer lag when using manual partition assignment with the KafkaConsumer
Date Thu, 03 Nov 2016 11:07:55 GMT

some Flink users recently noticed that they can not check the consumer lag
when using Flink's kafka consumer [1]. According to this discussion on the
Kafka user list [2] the kafka-consumer-groups.sh utility doesn't work with
KafkaConsumers with manual partition assignment.

Is there a way to get the consumer lag for a consumer that regularly
commits its offsets to the broker?


[1] https://issues.apache.org/jira/browse/FLINK-5001

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message