private void addDefaultBrokerPropsIfAbsent(Properties brokerConfig, int numBrokers) {
        brokerConfig.putIfAbsent(GroupCoordinatorConfig.GROUP_INITIAL_REBALANCE_DELAY_MS_CONFIG, "0");
        brokerConfig.putIfAbsent(GroupCoordinatorConfig.OFFSETS_TOPIC_REPLICATION_FACTOR_CONFIG, String.valueOf(numBrokers));
        brokerConfig.putIfAbsent(ServerLogConfigs.AUTO_CREATE_TOPICS_ENABLE_CONFIG, "false");
    }
List the latest current offsets for the given {@link Collection} of {@link TopicPartition topic partitions}
@param maxDurationMs the max duration to wait for while fetching metadata from Kafka (in milliseconds)
@param admin the admin client to use for fetching metadata from the Kafka cluster
@param topicPartitions the topic partitions to list end offsets for
@return a {@link Map} containing the latest offset for each requested {@link TopicPartition topic partition}; never null, and never empty
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedKafkaCluster.java