nileshkumar3 commented on code in PR #22816:
URL: https://github.com/apache/kafka/pull/22816#discussion_r3575890295
##########
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:
Correct — the later calls read an already-resolved regex state, and the
topic2/topic3 calls that do trigger a fresh async refresh are already wrapped
in TestUtils.retry.
--
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]
