nileshkumar3 opened a new pull request, #22816: URL: https://github.com/apache/kafka/pull/22816
## Cause `testConsumerGroupHeartbeatWithRegexWithDifferentMemberAcls` drives a regex-based (`^top.*`) consumer group heartbeat. Regex resolution on the broker is asynchronous: the first heartbeat only *schedules* the resolution, so the follow-up heartbeat that asserts member1 has a 2-partition assignment can run before resolution completes. On slower/loaded CI hosts the assignment is still empty and `assertEquals(2, ...)` fails intermittently . ## Change Wrap the first `sendAndReceiveRegexHeartbeat(..., Some(2))` for member1 in `TestUtils.tryUntilNoAssertionError`, so the test retries the heartbeat/assertion until the asynchronous regex resolution completes and the assignment is available. This mirrors the pattern already used elsewhere in the same test (`tryUntilNoAssertionError`) and `TestUtils.retry` for the later regex refreshes. Test-only change; no production code affected. Jira: https://issues.apache.org/jira/browse/KAFKA-20781 Reviewers - @lianetm -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
