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
