Class KafkaAdminClient


  • public class KafkaAdminClient
    extends Object
    Vert.x Kafka Admin client implementation

    NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

    • Field Detail

      • __TYPE_ARG

        public static final io.vertx.lang.rx.TypeArg<KafkaAdminClient> __TYPE_ARG
    • Constructor Detail

      • KafkaAdminClient

        public KafkaAdminClient​(Object delegate)
    • Method Detail

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object
      • create

        public 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
      • listTopics

        public Single<Set<String>> listTopics()
        List the topics available in the cluster with the default options.
        Returns:
        a future notified with the result
      • rxListTopics

        public Single<Set<String>> rxListTopics()
        List the topics available in the cluster with the default options.
        Returns:
        a future notified with the result
      • describeTopics

        public Single<Map<String,​TopicDescription>> describeTopics​(List<String> topicNames)
        Describe some topics in the cluster, with the default options.
        Parameters:
        topicNames - the names of the topics to describe
        Returns:
        a future notified with the result
      • rxDescribeTopics

        public Single<Map<String,​TopicDescription>> rxDescribeTopics​(List<String> topicNames)
        Describe some topics in the cluster, with the default options.
        Parameters:
        topicNames - the names of the topics to describe
        Returns:
        a future notified with the result
      • createTopics

        public Completable createTopics​(List<NewTopic> topics)
        Creates a batch of new Kafka topics
        Parameters:
        topics - topics to create
        Returns:
        a future notified with the result
      • rxCreateTopics

        public Completable rxCreateTopics​(List<NewTopic> topics)
        Creates a batch of new Kafka topics
        Parameters:
        topics - topics to create
        Returns:
        a future notified with the result
      • deleteTopics

        public Completable deleteTopics​(List<String> topicNames)
        Deletes a batch of Kafka topics
        Parameters:
        topicNames - the names of the topics to delete
        Returns:
        a future notified with the result
      • rxDeleteTopics

        public Completable rxDeleteTopics​(List<String> topicNames)
        Deletes a batch of Kafka topics
        Parameters:
        topicNames - the names of the topics to delete
        Returns:
        a future notified with the result
      • createPartitions

        public Completable createPartitions​(Map<String,​NewPartitions> partitions)
        Creates a batch of new partitions in the Kafka topic
        Parameters:
        partitions - partitions to create
        Returns:
        a future notified with the result
      • rxCreatePartitions

        public Completable rxCreatePartitions​(Map<String,​NewPartitions> partitions)
        Creates a batch of new partitions in the Kafka topic
        Parameters:
        partitions - partitions to create
        Returns:
        a future notified with the result
      • listConsumerGroups

        public Single<List<ConsumerGroupListing>> listConsumerGroups()
        Get the the consumer groups available in the cluster with the default options
        Returns:
        a future notified with the result
      • rxListConsumerGroups

        public Single<List<ConsumerGroupListing>> rxListConsumerGroups()
        Get the the consumer groups available in the cluster with the default options
        Returns:
        a future notified with the result
      • describeConsumerGroups

        public Single<Map<String,​ConsumerGroupDescription>> describeConsumerGroups​(List<String> groupIds)
        Describe some group ids in the cluster, with the default options
        Parameters:
        groupIds - the ids of the groups to describe
        Returns:
        a future notified with the result
      • rxDescribeConsumerGroups

        public Single<Map<String,​ConsumerGroupDescription>> rxDescribeConsumerGroups​(List<String> groupIds)
        Describe some group ids in the cluster, with the default options
        Parameters:
        groupIds - the ids of the groups to describe
        Returns:
        a future notified with the result
      • describeCluster

        public Single<ClusterDescription> describeCluster()
        Describe the nodes in the cluster with the default options
        Returns:
        a future notified with the result
      • rxDescribeCluster

        public Single<ClusterDescription> rxDescribeCluster()
        Describe the nodes in the cluster with the default options
        Returns:
        a future notified with the result
      • deleteConsumerGroups

        public Completable deleteConsumerGroups​(List<String> groupIds)
        Delete consumer groups from the cluster.
        Parameters:
        groupIds - the ids of the groups to delete
        Returns:
        a future notified with the result
      • rxDeleteConsumerGroups

        public Completable rxDeleteConsumerGroups​(List<String> groupIds)
        Delete consumer groups from the cluster.
        Parameters:
        groupIds - the ids of the groups to delete
        Returns:
        a future notified with the result
      • deleteConsumerGroupOffsets

        public Completable deleteConsumerGroupOffsets​(String groupId,
                                                      Set<TopicPartition> partitions)
        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 deleted
        partitions -
        Returns:
        a future notified with the result
      • rxDeleteConsumerGroupOffsets

        public Completable rxDeleteConsumerGroupOffsets​(String groupId,
                                                        Set<TopicPartition> partitions)
        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 deleted
        partitions -
        Returns:
        a future notified with the result
      • close

        public Completable close()
        Close the admin client
        Returns:
        a future notified with the result
      • rxClose

        public Completable rxClose()
        Close the admin client
        Returns:
        a future notified with the result
      • close

        public Completable close​(long timeout)
        Close the admin client
        Parameters:
        timeout - timeout to wait for closing
        Returns:
        a future notified with the result
      • rxClose

        public Completable rxClose​(long timeout)
        Close the admin client
        Parameters:
        timeout - timeout to wait for closing
        Returns:
        a future notified with the result
      • describeAcls

        public Single<List<org.apache.kafka.common.acl.AclBinding>> describeAcls​(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter)
        Describe the ACL rules.
        Parameters:
        aclBindingFilter - The filter to use.
        Returns:
        a future notified with the result
      • rxDescribeAcls

        public Single<List<org.apache.kafka.common.acl.AclBinding>> rxDescribeAcls​(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter)
        Describe the ACL rules.
        Parameters:
        aclBindingFilter - The filter to use.
        Returns:
        a future notified with the result
      • createAcls

        public Single<List<org.apache.kafka.common.acl.AclBinding>> createAcls​(List<org.apache.kafka.common.acl.AclBinding> aclBindings)
        Create the ACL rules.
        Parameters:
        aclBindings - The ACL to create.
        Returns:
        a future notified with the result
      • rxCreateAcls

        public Single<List<org.apache.kafka.common.acl.AclBinding>> rxCreateAcls​(List<org.apache.kafka.common.acl.AclBinding> aclBindings)
        Create the ACL rules.
        Parameters:
        aclBindings - The ACL to create.
        Returns:
        a future notified with the result
      • deleteAcls

        public Single<List<org.apache.kafka.common.acl.AclBinding>> deleteAcls​(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings)
        Delete the ACL rules.
        Parameters:
        aclBindings - The filter to delete matching ACLs.
        Returns:
        a future notified with the result
      • rxDeleteAcls

        public Single<List<org.apache.kafka.common.acl.AclBinding>> rxDeleteAcls​(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings)
        Delete the ACL rules.
        Parameters:
        aclBindings - The filter to delete matching ACLs.
        Returns:
        a future notified with the result