Sahil Aggarwal created KAFKA-6581: ------------------------------------- Summary: ConsumerGroupCommand hangs if even one of the partition is unavailable Key: KAFKA-6581 URL: https://issues.apache.org/jira/browse/KAFKA-6581 Project: Kafka Issue Type: Bug Components: admin, core, tools Affects Versions: 0.10.0.0 Reporter: Sahil Aggarwal Fix For: 0.10.0.2
ConsumerGroupCommand.scala uses consumer internally to get the position for each partition but if the partition is unavailable the call consumer.position(topicPartition) will block indefinitely. -- This message was sent by Atlassian JIRA (v7.6.3#76005)