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
Hi,

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?

Regards,
Robert


[1] https://issues.apache.org/jira/browse/FLINK-5001
[2]
http://grokbase.com/t/kafka/users/163rrq9ne8/new-consumer-group-not-showing-up

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