public static Cluster clusterWith(final int nodes, final String topic, final int partitions) {
        return clusterWith(nodes, Collections.singletonMap(topic, partitions));
    }
Helper functions for writing unit tests
clients/src/test/java/org/apache/kafka/test/TestUtils.java