showuon commented on pull request #11681: URL: https://github.com/apache/kafka/pull/11681#issuecomment-1030829409
@dajac , it doesn't work to put the admin client creating after `cluster.waitForReadyBrokers()`, because the waitForReadyBrokers only wait for all brokers registered and unfenced (ref: [here](https://github.com/apache/kafka/blob/trunk/core/src/test/java/kafka/testkit/KafkaClusterTestKit.java#L375)), but the metadata cache in broker might have not updated the cluster metadata. I think we need to explicitly wait for all brokers up via `describeCluster` and then create adminClient for testing. WDYT? -- 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]
