@Test
    public void shouldRetryCreateTopicWhenAvailableBrokersAreNotEnoughForReplicationFactor() {
        Cluster cluster = createCluster(1);
        NewTopic newTopic = TopicAdmin.defineTopic("myTopic").partitions(1).replicationFactor((short) 2).compacted().build();

        try (TopicAdmin admin = Mockito.spy(new TopicAdmin(new MockAdminClient(cluster.nodes(), cluster.nodeById(0))))) {
            try {
                admin.createTopicsWithRetry(newTopic, 2, 1, new MockTime());
            } catch (Exception e) {
                // not relevant
                e.printStackTrace();
            }
            Mockito.verify(admin, Mockito.times(2)).createTopics(newTopic);
        }
    }
0.11.0.0 clients can talk with older brokers, but the CREATE_TOPIC API was added in 0.10.1.0. That means,
if our TopicAdmin talks to a pre 0.10.1 broker, it should receive an UnsupportedVersionException, should
create no topics, and return false.
connect/runtime/src/test/java/org/apache/kafka/connect/util/TopicAdminTest.java