Consumer group describe issue

[sahil aggarwal]

Hi,

Facing issue where *kafka-consumer-groups.sh --describe * get stuck if one
of the partition is unavailable i.e no leader. Going through some code
found that it does following to get log end offset:

* Create consumer
* For each partition
   * assign partition
   * seek to end
   * get position

Issue is KafkaConsumer.posiiton() use Fetcher.retrieveOffsetsByTimes()
internally which is called with timeout Long.MAX_VALUE and it gets stuck in
loop there.


Any pointers?


*Version*: 0.10.0.1


Thanks,
Sahil