io.vertx.kafka.admin

## Interface KafkaAdminClient

-     public interface KafkaAdminClient

  Vert.x Kafka Admin client implementation

- - ### Method Summary

    All Methods Static Methods Instance Methods Abstract Methods Default Methods
    Modifier and Type | Method and Description
    --- | ---
    `Future<Void>` | `alterConfigs(Map<ConfigResource,Config> configs)` Like `alterConfigs(Map, Handler)` but returns a `Future` of the asynchronous result
    `void` | `alterConfigs(Map<ConfigResource,Config> configs, Handler<AsyncResult<Void>> completionHandler)` Update the configuration for the specified resources with the default options
    `Future<Void>` | `close()` Like `close(Handler)` but returns a `Future` of the asynchronous result
    `void` | `close(Handler<AsyncResult<Void>> handler)` Close the admin client
    `Future<Void>` | `close(long timeout)` Like `close(long, Handler)` but returns a `Future` of the asynchronous result
    `void` | `close(long timeout, Handler<AsyncResult<Void>> handler)` Close the admin client
    `static KafkaAdminClient` | `create(Vertx vertx, org.apache.kafka.clients.admin.AdminClient adminClient)` Create a new KafkaAdminClient instance
    `static KafkaAdminClient` | `create(Vertx vertx, Map<String,String> config)` Create a new KafkaAdminClient instance
    `static KafkaAdminClient` | `create(Vertx vertx, Properties config)` Create a new KafkaAdminClient instance
    `Future<Void>` | `createTopics(List<NewTopic> topics)` Like `createTopics(List, Handler)` but returns a `Future` of the asynchronous result
    `void` | `createTopics(List<NewTopic> topics, Handler<AsyncResult<Void>> completionHandler)` Creates a batch of new Kafka topics
    `Future<Void>` | `deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)` Like `deleteConsumerGroupOffsets(String, Set, Handler)` but returns a `Future` of the asynchronous result
    `void` | `deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions, Handler<AsyncResult<Void>> completionHandler)` Delete committed offsets for a set of partitions in a consumer group.
    `Future<Void>` | `deleteConsumerGroups(List<String> groupIds)` Like `deleteConsumerGroups(List, Handler)` but returns a `Future` of the asynchronous result
    `void` | `deleteConsumerGroups(List<String> groupIds, Handler<AsyncResult<Void>> completionHandler)` Delete consumer groups from the cluster.
    `Future<Void>` | `deleteTopics(List<String> topicNames)` Like `deleteTopics(List, Handler)` but returns a `Future` of the asynchronous result
    `void` | `deleteTopics(List<String> topicNames, Handler<AsyncResult<Void>> completionHandler)` Deletes a batch of Kafka topics
    `Future<ClusterDescription>` | `describeCluster()` Like `describeCluster(Handler)` but returns a `Future` of the asynchronous result
    `void` | `describeCluster(Handler<AsyncResult<ClusterDescription>> completionHandler)` Describe the nodes in the cluster with the default options
    `Future<Map<ConfigResource,Config>>` | `describeConfigs(List<ConfigResource> configResources)` Like `describeConfigs(List, Handler)` but returns a `Future` of the asynchronous result
    `void` | `describeConfigs(List<ConfigResource> configResources, Handler<AsyncResult<Map<ConfigResource,Config>>> completionHandler)` Get the configuration for the specified resources with the default options
    `Future<Map<String,ConsumerGroupDescription>>` | `describeConsumerGroups(List<String> groupIds)` Like `describeConsumerGroups(List, Handler)` but returns a `Future` of the asynchronous result
    `void` | `describeConsumerGroups(List<String> groupIds, Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)` Describe some group ids in the cluster, with the default options
    `Future<Map<String,TopicDescription>>` | `describeTopics(List<String> topicNames)` Like `describeTopics(List, Handler)` but returns a `Future` of the asynchronous result
    `void` | `describeTopics(List<String> topicNames, Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)` Describe some topics in the cluster, with the default options.
    `default Future<Map<TopicPartition,OffsetAndMetadata>>` | `listConsumerGroupOffsets(String groupId)` Like `listConsumerGroupOffsets(String, Handler)` but returns a `Future` of the asynchronous result
    `default void` | `listConsumerGroupOffsets(String groupId, Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)` List the consumer group offsets available in the cluster.
    `Future<Map<TopicPartition,OffsetAndMetadata>>` | `listConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsOptions options)` Like `listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions, Handler)` but returns a `Future` of the asynchronous result
    `void` | `listConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsOptions options, Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)` List the consumer group offsets available in the cluster.
    `Future<List<ConsumerGroupListing>>` | `listConsumerGroups()` Like `listConsumerGroups(Handler)` but returns a `Future` of the asynchronous result
    `void` | `listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)` Get the the consumer groups available in the cluster with the default options
    `Future<Map<TopicPartition,ListOffsetsResultInfo>>` | `listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets)` Like `#listOffsets(Map, Handler)` but returns a `Future` of the asynchronous result
    `void` | `listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets, Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler)` List the offsets available for a set of partitions.
    `Future<Set<String>>` | `listTopics()` Like `listTopics(Handler)` but returns a `Future` of the asynchronous result
    `void` | `listTopics(Handler<AsyncResult<Set<String>>> completionHandler)` List the topics available in the cluster with the default options.

- - ### Method Detail

    - #### create

          static KafkaAdminClient create(Vertx vertx,
                                         org.apache.kafka.clients.admin.AdminClient adminClient)

      Create a new KafkaAdminClient instance
      Parameters:
        `vertx` - Vert.x instance to use
        `adminClient` - Kafka native Admin client instance
      Returns:
        an instance of the KafkaAdminClient

    - #### create

          static KafkaAdminClient create(Vertx vertx,
                                         Map<String,String> config)

      Create a new KafkaAdminClient instance
      Parameters:
        `vertx` - Vert.x instance to use
        `config` - Kafka admin client configuration
      Returns:
        an instance of the KafkaAdminClient

    - #### create

          static KafkaAdminClient create(Vertx vertx,
                                         Properties config)

      Create a new KafkaAdminClient instance
      Parameters:
        `vertx` - Vert.x instance to use
        `config` - Kafka admin client configuration
      Returns:
        an instance of the KafkaAdminClient

    - #### listTopics

          void listTopics(Handler<AsyncResult<Set<String>>> completionHandler)

      List the topics available in the cluster with the default options.
      Parameters:
        `completionHandler` - handler called on operation completed with the topics set

    - #### listTopics

          Future<Set<String>> listTopics()

      Like `listTopics(Handler)` but returns a `Future` of the asynchronous result

    - #### describeTopics

          void describeTopics(List<String> topicNames,
                              Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)

      Describe some topics in the cluster, with the default options.
      Parameters:
        `topicNames` - the names of the topics to describe
        `completionHandler` - handler called on operation completed with the topics descriptions

    - #### describeTopics

          Future<Map<String,TopicDescription>> describeTopics(List<String> topicNames)

      Like `describeTopics(List, Handler)` but returns a `Future` of the asynchronous result

    - #### createTopics

          void createTopics(List<NewTopic> topics,
                            Handler<AsyncResult<Void>> completionHandler)

      Creates a batch of new Kafka topics
      Parameters:
        `topics` - topics to create
        `completionHandler` - handler called on operation completed

    - #### createTopics

          Future<Void> createTopics(List<NewTopic> topics)

      Like `createTopics(List, Handler)` but returns a `Future` of the asynchronous result

    - #### deleteTopics

          void deleteTopics(List<String> topicNames,
                            Handler<AsyncResult<Void>> completionHandler)

      Deletes a batch of Kafka topics
      Parameters:
        `topicNames` - the names of the topics to delete
        `completionHandler` - handler called on operation completed

    - #### deleteTopics

          Future<Void> deleteTopics(List<String> topicNames)

      Like `deleteTopics(List, Handler)` but returns a `Future` of the asynchronous result

    - #### describeConfigs

          void describeConfigs(List<ConfigResource> configResources,
                               Handler<AsyncResult<Map<ConfigResource,Config>>> completionHandler)

      Get the configuration for the specified resources with the default options
      Parameters:
        `configResources` - the resources (topic and broker resource types are currently supported)
        `completionHandler` - handler called on operation completed with the configurations

    - #### describeConfigs

          Future<Map<ConfigResource,Config>> describeConfigs(List<ConfigResource> configResources)

      Like `describeConfigs(List, Handler)` but returns a `Future` of the asynchronous result

    - #### alterConfigs

          void alterConfigs(Map<ConfigResource,Config> configs,
                            Handler<AsyncResult<Void>> completionHandler)

      Update the configuration for the specified resources with the default options
      Parameters:
        `configs` - The resources with their configs (topic is the only resource type with configs that can be updated currently)
        `completionHandler` - handler called on operation completed

    - #### alterConfigs

          Future<Void> alterConfigs(Map<ConfigResource,Config> configs)

      Like `alterConfigs(Map, Handler)` but returns a `Future` of the asynchronous result

    - #### listConsumerGroups

          void listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)

      Get the the consumer groups available in the cluster with the default options
      Parameters:
        `completionHandler` - handler called on operation completed with the consumer groups ids

    - #### listConsumerGroups

          Future<List<ConsumerGroupListing>> listConsumerGroups()

      Like `listConsumerGroups(Handler)` but returns a `Future` of the asynchronous result

    - #### describeConsumerGroups

          void describeConsumerGroups(List<String> groupIds,
                                      Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)

      Describe some group ids in the cluster, with the default options
      Parameters:
        `groupIds` - the ids of the groups to describe
        `completionHandler` - handler called on operation completed with the consumer groups descriptions

    - #### describeConsumerGroups

          Future<Map<String,ConsumerGroupDescription>> describeConsumerGroups(List<String> groupIds)

      Like `describeConsumerGroups(List, Handler)` but returns a `Future` of the asynchronous result

    - #### describeCluster

          void describeCluster(Handler<AsyncResult<ClusterDescription>> completionHandler)

      Describe the nodes in the cluster with the default options
      Parameters:
        `completionHandler` - handler called on operation completed with the cluster description

    - #### describeCluster

          Future<ClusterDescription> describeCluster()

      Like `describeCluster(Handler)` but returns a `Future` of the asynchronous result

    - #### deleteConsumerGroups

          void deleteConsumerGroups(List<String> groupIds,
                                    Handler<AsyncResult<Void>> completionHandler)

      Delete consumer groups from the cluster.
      Parameters:
        `groupIds` - the ids of the groups to delete
        `completionHandler` - handler called on operation completed

    - #### deleteConsumerGroups

          Future<Void> deleteConsumerGroups(List<String> groupIds)

      Like `deleteConsumerGroups(List, Handler)` but returns a `Future` of the asynchronous result

    - #### listConsumerGroupOffsets

          void listConsumerGroupOffsets(String groupId,
                                        ListConsumerGroupOffsetsOptions options,
                                        Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)

      List the consumer group offsets available in the cluster.
      Parameters:
        `groupId` - The group id of the group whose offsets will be listed
        `options` - The options to use when listing the consumer group offsets.
        `completionHandler` - handler called on operation completed with the consumer groups offsets

    - #### listConsumerGroupOffsets

          Future<Map<TopicPartition,OffsetAndMetadata>> listConsumerGroupOffsets(String groupId,
                                                                                 ListConsumerGroupOffsetsOptions options)

      Like `listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions, Handler)` but returns a `Future` of the asynchronous result

    - #### listConsumerGroupOffsets

          default void listConsumerGroupOffsets(String groupId,
                                                Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)

      List the consumer group offsets available in the cluster.
      Parameters:
        `groupId` - The group id of the group whose offsets will be listed
        `completionHandler` - handler called on operation completed with the consumer groups offsets

    - #### listConsumerGroupOffsets

          default Future<Map<TopicPartition,OffsetAndMetadata>> listConsumerGroupOffsets(String groupId)

      Like `listConsumerGroupOffsets(String, Handler)` but returns a `Future` of the asynchronous result

    - #### deleteConsumerGroupOffsets

          void deleteConsumerGroupOffsets(String groupId,
                                          Set<TopicPartition> partitions,
                                          Handler<AsyncResult<Void>> completionHandler)

      Delete committed offsets for a set of partitions in a consumer group. This will succeed at the partition level only if the group is not actively subscribed to the corresponding topic.
      Parameters:
        `groupId` - The group id of the group whose offsets will be listed
        `partitions` - The set of partitions in the consumer group whose offsets will be deleted

    - #### deleteConsumerGroupOffsets

          Future<Void> deleteConsumerGroupOffsets(String groupId,
                                                  Set<TopicPartition> partitions)

      Like `deleteConsumerGroupOffsets(String, Set, Handler)` but returns a `Future` of the asynchronous result

    - #### listOffsets

          void listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets,
                           Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler)

      List the offsets available for a set of partitions.
      Parameters:
        `topicPartitionOffsets` - The options to use when listing the partition offsets.
        `completionHandler` - handler called on operation completed with the partition offsets

    - #### listOffsets

          Future<Map<TopicPartition,ListOffsetsResultInfo>> listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets)

      Like `#listOffsets(Map, Handler)` but returns a `Future` of the asynchronous result

    - #### close

          void close(Handler<AsyncResult<Void>> handler)

      Close the admin client
      Parameters:
        `handler` - a `Handler` completed with the operation result

    - #### close

          Future<Void> close()

      Like `close(Handler)` but returns a `Future` of the asynchronous result

    - #### close

          void close(long timeout,
                     Handler<AsyncResult<Void>> handler)

      Close the admin client
      Parameters:
        `timeout` - timeout to wait for closing
        `handler` - a `Handler` completed with the operation result

    - #### close

          Future<Void> close(long timeout)

      Like `close(long, Handler)` but returns a `Future` of the asynchronous result

Copyright © 2021 Eclipse. All rights reserved.