[
https://issues.apache.org/jira/browse/KAFKA-8245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17028161#comment-17028161
]
ASF GitHub Bot commented on KAFKA-8245:
---------------------------------------
chia7712 commented on pull request #8032: KAFKA-8245 Flaky Test
DeleteConsumerGroupsTest#testDeleteCmdAllGroups
URL: https://github.com/apache/kafka/pull/8032
the root cause is the “shutdown” may obstruct consumer to complete the group
join. If the consumer wakes up before completing the partition assignments, the
consumer is in a state of UNJOINED (so it won’t send LeaveGroupRequest when
closing) and the broker is in a state of CompletingRebalance until timeout.
To fix the flaky, we should wait all groups are in Stable state to make sure
all Consumers have completed the group joining (so they are able to send
LeaveGroupRequest when closing).
### 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 to 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
> Flaky Test DeleteConsumerGroupsTest#testDeleteCmdAllGroups
> ----------------------------------------------------------
>
> Key: KAFKA-8245
> URL: https://issues.apache.org/jira/browse/KAFKA-8245
> Project: Kafka
> Issue Type: Bug
> Components: admin, unit tests
> Affects Versions: 2.3.0
> Reporter: Matthias J. Sax
> Assignee: Chia-Ping Tsai
> Priority: Critical
> Labels: flaky-test
> Fix For: 2.5.0
>
>
> [https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/3781/testReport/junit/kafka.admin/DeleteConsumerGroupsTest/testDeleteCmdAllGroups/]
> {quote}java.lang.AssertionError: The group did become empty as expected. at
> kafka.utils.TestUtils$.fail(TestUtils.scala:381) at
> kafka.utils.TestUtils$.waitUntilTrue(TestUtils.scala:791) at
> kafka.admin.DeleteConsumerGroupsTest.testDeleteCmdAllGroups(DeleteConsumerGroupsTest.scala:148){quote}
> STDOUT
> {quote}Error: Deletion of some consumer groups failed: * Group 'test.group'
> could not be deleted due to: java.util.concurrent.ExecutionException:
> org.apache.kafka.common.errors.GroupNotEmptyException: The group is not
> empty. Error: Deletion of some consumer groups failed: * Group
> 'missing.group' could not be deleted due to:
> java.util.concurrent.ExecutionException:
> org.apache.kafka.common.errors.GroupIdNotFoundException: The group id does
> not exist. [2019-04-16 09:42:02,316] WARN Unable to read additional data from
> client sessionid 0x104f958dba30000, likely client has closed socket
> (org.apache.zookeeper.server.NIOServerCnxn:376) Deletion of requested
> consumer groups ('test.group') was successful. Error: Deletion of some
> consumer groups failed: * Group 'missing.group' could not be deleted due to:
> java.util.concurrent.ExecutionException:
> org.apache.kafka.common.errors.GroupIdNotFoundException: The group id does
> not exist. These consumer groups were deleted successfully:
> 'test.group'{quote}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
