[
https://issues.apache.org/jira/browse/KAFKA-4948?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16038946#comment-16038946
]
ASF GitHub Bot commented on KAFKA-4948:
---------------------------------------
GitHub user rajinisivaram opened a pull request:
https://github.com/apache/kafka/pull/3246
KAFKA-4948: Wait for offset commit in test to fix transient failure
`DescribeConsumerGroupTest#testDescribeExistingGroupWithNoMembersWithNewConsumer`
shuts down the consumer executor thread and then checks that the assignments
returned by `describeGroup` contain the consume group with no members. But if
the executor thread is shut down before any offsets are committed, the
assignments returned by `describeGroup` doesn't contain the group at all. This
PR waits for an offset commit by waiting for the group to appear in
`describeGroup` assignments prior to shutting down the executor.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/rajinisivaram/kafka KAFKA-4948
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/kafka/pull/3246.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3246
----
commit cda6b607e83078f5941731b73d7c38575606d473
Author: Rajini Sivaram <[email protected]>
Date: 2017-06-06T13:28:16Z
KAFKA-4948: Wait for offset commit in test to fix transient failure
----
> Failure in
> kafka.admin.DescribeConsumerGroupTest.testDescribeExistingGroupWithNoMembersWithNewConsumer
> ------------------------------------------------------------------------------------------------------
>
> Key: KAFKA-4948
> URL: https://issues.apache.org/jira/browse/KAFKA-4948
> Project: Kafka
> Issue Type: Sub-task
> Components: unit tests
> Reporter: Guozhang Wang
> Assignee: Rajini Sivaram
>
> We have seen this failure happening quite frequently in Jenkins.
> {code}
> TBD
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
