diff --git a/clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java b/clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java index 7a32bcf5a160b..57d670e04f907 100644 --- a/clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java +++ b/clients/src/test/java/org/apache/kafka/clients/admin/MockAdminClient.java @@ -391,13 +391,23 @@ synchronized public CreateTopicsResult createTopics(Collection newTopi topicIds.put(topicName, topicId); topicNames.put(topicId, topicName); allTopics.put(topicName, new TopicMetadata(topicId, false, partitions, logDirs, newTopic.configs())); - future.complete(null); + future.complete(new CreateTopicsResult.TopicMetadataAndConfig(topicId, numberOfPartitions, replicationFactor, config(newTopic))); createTopicResult.put(topicName, future); } return new CreateTopicsResult(createTopicResult); } + private static Config config(NewTopic newTopic) { + Collection configEntries = new ArrayList<>(); + if (newTopic.configs() != null) { + for (Map.Entry entry : newTopic.configs().entrySet()) { + configEntries.add(new ConfigEntry(entry.getKey(), entry.getValue())); + } + } + return new Config(configEntries); + } + @Override synchronized public ListTopicsResult listTopics(ListTopicsOptions options) { Map topicListings = new HashMap<>();