Fixed it by some code change in ConsumerGroupCommand.scala. Possible to push it upstream for 0.10.* ?
It seems to be fixed in 0.11.* where it uses getEndOffsets() which has requestTimeoutMs instead of Long.MAX_VALUE. On 23 December 2017 at 02:46, Matthias J. Sax <matth...@confluent.io> wrote: > Your observation is correct. KafkaConsumer.position() is a blocking > call. It's a know issue that there is no configurable timeout value. > > I am not aware of any workaround. > > > -Matthias > > On 12/21/17 6:05 AM, sahil aggarwal wrote: > > 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 > > > >
