    @Test
    public void testCreateTestTopic() throws ExecutionException, InterruptedException {

        TopicCreator tc = new TopicCreator(admin);
        tc.maybeCreateTopic("test.is.a.test.topic");
        verify(admin, times(1)).createTopics(any());
    }