[jira] [Created] (KAFKA-15775) Implement listTopics() and partitionFor() for the AsyncKafkaConsumer

[Philip Nee (Jira)]

Philip Nee created KAFKA-15775:
----------------------------------

             Summary: Implement listTopics() and partitionFor() for the 
AsyncKafkaConsumer
                 Key: KAFKA-15775
                 URL: https://issues.apache.org/jira/browse/KAFKA-15775
             Project: Kafka
          Issue Type: Task
            Reporter: Philip Nee


{code:java}
@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");
} {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)