ShivsundarR opened a new pull request, #19647: URL: https://github.com/apache/kafka/pull/19647
https://issues.apache.org/jira/browse/KAFKA-19229 *What* - A couple of newly added tests were found to be flaky in `AuthorizerIntegrationTest.scala`. - `testShareGroupDescribeWithGroupDescribeAndTopicDescribeAcl` and `testShareGroupDescribeWithoutGroupDescribeAcl` - Logs indicated that the test fails when the following condition happens : When the background error event arrives after the consumer had unsubscribed, then these events are processed in the `handleCompletedAcknowledgements` method and the exception from the event is thrown, preventing `close()` to complete. As the `close()` method fails, the test also fails in these cases. *Fix* - PR fixes this by ignoring the exceptions in the background queue when the `handleCompletedAcknowledgements` method is called during `close()`. This ensures `close()` completes successfully. - Have added a unit test which mimics the race condition as well. -- 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. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
