TaiJuWu commented on code in PR #16852:
URL: https://github.com/apache/kafka/pull/16852#discussion_r1720605809
##########
core/src/test/java/kafka/test/ClusterInstance.java:
##########
@@ -187,6 +188,21 @@ default void waitTopicDeletion(String topic) throws
InterruptedException {
waitForTopic(topic, 0);
}
+ default long waitForMeatdataSync() throws InterruptedException {
Review Comment:
Yes, it is not used now.
This comes from `TestUtils.ensureConsistentKRaftMetadata` and I think it can
help new infra user easy to sync metadata.
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]
