Implement listTopics() and partitionFor() for the AsyncKafkaConsumer

@Override
public List<PartitionInfo> partitionsFor(String topic) {
    return partitionsFor(topic, Duration.ofMillis(defaultApiTimeoutMs));
}

@Override
public List<PartitionInfo> partitionsFor(String topic, Duration timeout) {
    throw new KafkaException("method not implemented");
}

@Override
public Map<String, List<PartitionInfo>> listTopics() {
    return listTopics(Duration.ofMillis(defaultApiTimeoutMs));
}

@Override
public Map<String, List<PartitionInfo>> listTopics(Duration timeout) {
    throw new KafkaException("method not implemented");
}