You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/02/22 11:10:00 UTC

[jira] [Commented] (KAFKA-6581) ConsumerGroupCommand hangs if even one of the partition is unavailable

    [ 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:
users@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)