[
https://issues.apache.org/jira/browse/KAFKA-6581?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16372688#comment-16372688
]
ASF GitHub Bot commented on KAFKA-6581:
---------------------------------------
SahilAggarwal opened a new pull request #4612: KAFKA-6581: Fix the
ConsumerGroupCommand indefinite execution if one of the partition is
unavailable.
URL: https://github.com/apache/kafka/pull/4612
* Checks if partition available before calling consumer.position
* Adds timeout on consumer.position() call.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> 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
> Priority: Major
> 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)
