diff --git a/clients/src/test/java/org/apache/kafka/clients/MockClient.java b/clients/src/test/java/org/apache/kafka/clients/MockClient.java index 23b7bf2418b..f9a37e2cdde 100644 --- a/clients/src/test/java/org/apache/kafka/clients/MockClient.java +++ b/clients/src/test/java/org/apache/kafka/clients/MockClient.java @@ -541,6 +541,10 @@ public class MockClient implements KafkaClient { metadataUpdates.add(new MetadataUpdate(updateResponse, expectMatchMetadataTopics)); } + public int preparedMetadataUpdatesCount() { + return metadataUpdates.size(); + } + public void updateMetadata(MetadataResponse updateResponse) { metadataUpdater.update(time, new MetadataUpdate(updateResponse, false)); }