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

["Andrew Schofield (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Andrew Schofield resolved KAFKA-15775.
--------------------------------------
    Resolution: Fixed

> Implement listTopics() and partitionFor() for the AsyncKafkaConsumer
> --------------------------------------------------------------------
>
>                 Key: KAFKA-15775
>                 URL: https://issues.apache.org/jira/browse/KAFKA-15775
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: clients, consumer
>            Reporter: Philip Nee
>            Assignee: Andrew Schofield
>            Priority: Major
>              Labels: consumer-threading-refactor, kip-848, kip-848-client-support, kip-848-e2e, kip-848-preview
>
> {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)