CompletableFuture<Void> create(List<TopicInfo> topicInfos) {
        return CompletableFuture.runAsync(() -> createBlocking(topicInfos));
    }
@Test
    void created() {
        KafkaFuture<Void> future = KafkaFuture.completedFuture(null);

        when(createTopicsResult.values()).thenReturn(singletonMap(topic, future));

        topicCreator.create(singletonList(topicInfo)).join();

        verify(admin).createTopics(captor.capture());

        List<List<NewTopic>> allValues = captor.getAllValues();
        assertThat(allValues).hasSize(1);
        assertNewTopics(allValues.get(0));
    }