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