lianetm commented on code in PR #22816:
URL: https://github.com/apache/kafka/pull/22816#discussion_r3573657396
##########
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala:
##########
@@ -3196,9 +3196,13 @@ class AuthorizerIntegrationTest extends
AbstractAuthorizerIntegrationTest {
val allowAllOpsAcl = new AccessControlEntry(clientPrincipalString,
WILDCARD_HOST, ALL, ALLOW)
addAndVerifyAcls(Set(allowAllOpsAcl), groupResource)
- // Member on inter-broker listener has all access and is assigned the
matching topic
+ // Member on inter-broker listener has all access and is assigned the
matching topic.
+ // The first heartbeat only schedules the asynchronous regex resolution,
so retry until
+ // the resolution completes and the assignment is available.
var member1Response =
sendAndReceiveFirstRegexHeartbeat("memberWithAllAccess",
interBrokerListenerName)
- member1Response = sendAndReceiveRegexHeartbeat(member1Response,
interBrokerListenerName, Some(2))
+ TestUtils.tryUntilNoAssertionError() {
Review Comment:
I expect we don't need this same fix in the other similar calls in the test
because they all rely on the same regex (already resolved by then), correct?
--
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]
