Package io.vertx.mutiny.kafka.admin

Class KafkaAdminClient

java.lang.Object
io.vertx.mutiny.kafka.admin.KafkaAdminClient
All Implemented Interfaces:
MutinyDelegate
public class KafkaAdminClient extends Object implements MutinyDelegate
Vert.x Kafka Admin client implementation

NOTE: This class has been automatically generated from the original non Mutiny-ified interface.

See Also:
  • KafkaAdminClient

  • Field Details

  • Constructor Details

    • KafkaAdminClient

      public KafkaAdminClient(io.vertx.kafka.admin.KafkaAdminClient delegate)
      Create a new instance of KafkaAdminClient delegating to the given (non-null) instance of KafkaAdminClient.

    • KafkaAdminClient

      public KafkaAdminClient(Object delegate)

  • Method Details

    • getDelegate

      public io.vertx.kafka.admin.KafkaAdminClient getDelegate()
      Get the delegate instance.

      This method returns the instance on which this shim is delegating the calls. And so, give you access to the bare API.

      Specified by:
      getDelegate in interface MutinyDelegate
      Returns:
      the delegate instance

    • listTopics

      @CheckReturnValue public io.smallrye.mutiny.Uni<Set<String>> listTopics()
      List the topics available in the cluster with the default options.

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.listTopics()

    • listTopicsAndAwait

      public Set<String> listTopicsAndAwait()
      List the topics available in the cluster with the default options.

      Unlike the bare Vert.x variant, this method returns a Set<String>. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Returns:
      The operation result
      See Also:
      • KafkaAdminClient.listTopics()

    • listTopicsAndForget

      public KafkaAdminClient listTopicsAndForget()
      List the topics available in the cluster with the default options.

      Unlike the bare Vert.x variant, this method ignores the Set<String> result or any failure.

      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.listTopics()

    • describeTopics

      @CheckReturnValue public io.smallrye.mutiny.Uni<Map<String,io.vertx.kafka.admin.TopicDescription>> describeTopics(List<String> topicNames)
      Describe some topics in the cluster, with the default options.

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Parameters:
      topicNames - the names of the topics to describe
      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.describeTopics(List)

    • describeTopicsAndAwait

      public Map<String,io.vertx.kafka.admin.TopicDescription> describeTopicsAndAwait(List<String> topicNames)
      Describe some topics in the cluster, with the default options.

      Unlike the bare Vert.x variant, this method returns a Map<String,io.vertx.kafka.admin.TopicDescription>. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      topicNames - the names of the topics to describe
      Returns:
      The operation result
      See Also:
      • KafkaAdminClient.describeTopics(List)

    • describeTopicsAndForget

      public KafkaAdminClient describeTopicsAndForget(List<String> topicNames)
      Describe some topics in the cluster, with the default options.

      Unlike the bare Vert.x variant, this method ignores the Map<String,io.vertx.kafka.admin.TopicDescription> result or any failure.

      Parameters:
      topicNames - the names of the topics to describe
      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.describeTopics(List)

    • describeTopics

      @CheckReturnValue public io.smallrye.mutiny.Uni<Map<String,io.vertx.kafka.admin.TopicDescription>> describeTopics(List<String> topicNames, io.vertx.kafka.admin.DescribeTopicsOptions options)
      Like describeTopics(List) but allows for customised otions

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.describeTopics(List, DescribeTopicsOptions)

    • describeTopicsAndAwait

      public Map<String,io.vertx.kafka.admin.TopicDescription> describeTopicsAndAwait(List<String> topicNames, io.vertx.kafka.admin.DescribeTopicsOptions options)
      Like describeTopics(List) but allows for customised otions

      Unlike the bare Vert.x variant, this method returns a Map<String,io.vertx.kafka.admin.TopicDescription>. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Returns:
      The operation result
      See Also:
      • KafkaAdminClient.describeTopics(List, DescribeTopicsOptions)

    • describeTopicsAndForget

      public KafkaAdminClient describeTopicsAndForget(List<String> topicNames, io.vertx.kafka.admin.DescribeTopicsOptions options)
      Like describeTopics(List) but allows for customised otions

      Unlike the bare Vert.x variant, this method ignores the Map<String,io.vertx.kafka.admin.TopicDescription> result or any failure.

      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.describeTopics(List, DescribeTopicsOptions)

    • createTopics

      @CheckReturnValue public io.smallrye.mutiny.Uni<Void> createTopics(List<io.vertx.kafka.admin.NewTopic> topics)
      Creates a batch of new Kafka topics

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Parameters:
      topics - topics to create
      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.createTopics(List)

    • createTopicsAndAwait

      public void createTopicsAndAwait(List<io.vertx.kafka.admin.NewTopic> topics)
      Creates a batch of new Kafka topics

      Unlike the bare Vert.x variant, this method returns a Void. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      topics - topics to create
      See Also:
      • KafkaAdminClient.createTopics(List)

    • createTopicsAndForget

      public KafkaAdminClient createTopicsAndForget(List<io.vertx.kafka.admin.NewTopic> topics)
      Creates a batch of new Kafka topics

      Unlike the bare Vert.x variant, this method ignores the Void result or any failure.

      Parameters:
      topics - topics to create
      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.createTopics(List)

    • deleteTopics

      @CheckReturnValue public io.smallrye.mutiny.Uni<Void> deleteTopics(List<String> topicNames)
      Deletes a batch of Kafka topics

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Parameters:
      topicNames - the names of the topics to delete
      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.deleteTopics(List)

    • deleteTopicsAndAwait

      public void deleteTopicsAndAwait(List<String> topicNames)
      Deletes a batch of Kafka topics

      Unlike the bare Vert.x variant, this method returns a Void. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      topicNames - the names of the topics to delete
      See Also:
      • KafkaAdminClient.deleteTopics(List)

    • deleteTopicsAndForget

      public KafkaAdminClient deleteTopicsAndForget(List<String> topicNames)
      Deletes a batch of Kafka topics

      Unlike the bare Vert.x variant, this method ignores the Void result or any failure.

      Parameters:
      topicNames - the names of the topics to delete
      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.deleteTopics(List)

    • createPartitions

      @CheckReturnValue public io.smallrye.mutiny.Uni<Void> createPartitions(Map<String,io.vertx.kafka.admin.NewPartitions> partitions)
      Creates a batch of new partitions in the Kafka topic

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Parameters:
      partitions - partitions to create
      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.createPartitions(Map)

    • createPartitionsAndAwait

      public void createPartitionsAndAwait(Map<String,io.vertx.kafka.admin.NewPartitions> partitions)
      Creates a batch of new partitions in the Kafka topic

      Unlike the bare Vert.x variant, this method returns a Void. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      partitions - partitions to create
      See Also:
      • KafkaAdminClient.createPartitions(Map)

    • createPartitionsAndForget

      public KafkaAdminClient createPartitionsAndForget(Map<String,io.vertx.kafka.admin.NewPartitions> partitions)
      Creates a batch of new partitions in the Kafka topic

      Unlike the bare Vert.x variant, this method ignores the Void result or any failure.

      Parameters:
      partitions - partitions to create
      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.createPartitions(Map)

    • listConsumerGroups

      @CheckReturnValue public io.smallrye.mutiny.Uni<List<io.vertx.kafka.admin.ConsumerGroupListing>> listConsumerGroups()
      Get the the consumer groups available in the cluster with the default options

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.listConsumerGroups()

    • listConsumerGroupsAndAwait

      public List<io.vertx.kafka.admin.ConsumerGroupListing> listConsumerGroupsAndAwait()
      Get the the consumer groups available in the cluster with the default options

      Unlike the bare Vert.x variant, this method returns a List<io.vertx.kafka.admin.ConsumerGroupListing>. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Returns:
      The operation result
      See Also:
      • KafkaAdminClient.listConsumerGroups()

    • listConsumerGroupsAndForget

      public KafkaAdminClient listConsumerGroupsAndForget()
      Get the the consumer groups available in the cluster with the default options

      Unlike the bare Vert.x variant, this method ignores the List<io.vertx.kafka.admin.ConsumerGroupListing> result or any failure.

      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.listConsumerGroups()

    • describeConsumerGroups

      @CheckReturnValue public io.smallrye.mutiny.Uni<Map<String,io.vertx.kafka.admin.ConsumerGroupDescription>> describeConsumerGroups(List<String> groupIds)
      Describe some group ids in the cluster, with the default options

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Parameters:
      groupIds - the ids of the groups to describe
      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.describeConsumerGroups(List)

    • describeConsumerGroupsAndAwait

      public Map<String,io.vertx.kafka.admin.ConsumerGroupDescription> describeConsumerGroupsAndAwait(List<String> groupIds)
      Describe some group ids in the cluster, with the default options

      Unlike the bare Vert.x variant, this method returns a Map<String,io.vertx.kafka.admin.ConsumerGroupDescription>. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      groupIds - the ids of the groups to describe
      Returns:
      The operation result
      See Also:
      • KafkaAdminClient.describeConsumerGroups(List)

    • describeConsumerGroupsAndForget

      public KafkaAdminClient describeConsumerGroupsAndForget(List<String> groupIds)
      Describe some group ids in the cluster, with the default options

      Unlike the bare Vert.x variant, this method ignores the Map<String,io.vertx.kafka.admin.ConsumerGroupDescription> result or any failure.

      Parameters:
      groupIds - the ids of the groups to describe
      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.describeConsumerGroups(List)

    • describeConsumerGroups

      @CheckReturnValue public io.smallrye.mutiny.Uni<Map<String,io.vertx.kafka.admin.ConsumerGroupDescription>> describeConsumerGroups(List<String> groupIds, io.vertx.kafka.admin.DescribeConsumerGroupsOptions options)
      Like describeConsumerGroups(List) but allows customized options

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.describeConsumerGroups(List, DescribeConsumerGroupsOptions)

    • describeConsumerGroupsAndAwait

      public Map<String,io.vertx.kafka.admin.ConsumerGroupDescription> describeConsumerGroupsAndAwait(List<String> groupIds, io.vertx.kafka.admin.DescribeConsumerGroupsOptions options)
      Like describeConsumerGroups(List) but allows customized options

      Unlike the bare Vert.x variant, this method returns a Map<String,io.vertx.kafka.admin.ConsumerGroupDescription>. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Returns:
      The operation result
      See Also:
      • KafkaAdminClient.describeConsumerGroups(List, DescribeConsumerGroupsOptions)

    • describeConsumerGroupsAndForget

      public KafkaAdminClient describeConsumerGroupsAndForget(List<String> groupIds, io.vertx.kafka.admin.DescribeConsumerGroupsOptions options)
      Like describeConsumerGroups(List) but allows customized options

      Unlike the bare Vert.x variant, this method ignores the Map<String,io.vertx.kafka.admin.ConsumerGroupDescription> result or any failure.

      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.describeConsumerGroups(List, DescribeConsumerGroupsOptions)

    • describeCluster

      @CheckReturnValue public io.smallrye.mutiny.Uni<io.vertx.kafka.admin.ClusterDescription> describeCluster()
      Describe the nodes in the cluster with the default options

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.describeCluster()

    • describeClusterAndAwait

      public io.vertx.kafka.admin.ClusterDescription describeClusterAndAwait()
      Describe the nodes in the cluster with the default options

      Unlike the bare Vert.x variant, this method returns a ClusterDescription. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Returns:
      The operation result
      See Also:
      • KafkaAdminClient.describeCluster()

    • describeClusterAndForget

      public KafkaAdminClient describeClusterAndForget()
      Describe the nodes in the cluster with the default options

      Unlike the bare Vert.x variant, this method ignores the ClusterDescription result or any failure.

      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.describeCluster()

    • describeCluster

      @CheckReturnValue public io.smallrye.mutiny.Uni<io.vertx.kafka.admin.ClusterDescription> describeCluster(io.vertx.kafka.admin.DescribeClusterOptions options)
      Like describeCluster() but allows customized options.

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.describeCluster(DescribeClusterOptions)

    • describeClusterAndAwait

      public io.vertx.kafka.admin.ClusterDescription describeClusterAndAwait(io.vertx.kafka.admin.DescribeClusterOptions options)
      Like describeCluster() but allows customized options.

      Unlike the bare Vert.x variant, this method returns a ClusterDescription. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Returns:
      The operation result
      See Also:
      • KafkaAdminClient.describeCluster(DescribeClusterOptions)

    • describeClusterAndForget

      public KafkaAdminClient describeClusterAndForget(io.vertx.kafka.admin.DescribeClusterOptions options)
      Like describeCluster() but allows customized options.

      Unlike the bare Vert.x variant, this method ignores the ClusterDescription result or any failure.

      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.describeCluster(DescribeClusterOptions)

    • deleteConsumerGroups

      @CheckReturnValue public io.smallrye.mutiny.Uni<Void> deleteConsumerGroups(List<String> groupIds)
      Delete consumer groups from the cluster.

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Parameters:
      groupIds - the ids of the groups to delete
      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.deleteConsumerGroups(List)

    • deleteConsumerGroupsAndAwait

      public void deleteConsumerGroupsAndAwait(List<String> groupIds)
      Delete consumer groups from the cluster.

      Unlike the bare Vert.x variant, this method returns a Void. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      groupIds - the ids of the groups to delete
      See Also:
      • KafkaAdminClient.deleteConsumerGroups(List)

    • deleteConsumerGroupsAndForget

      public KafkaAdminClient deleteConsumerGroupsAndForget(List<String> groupIds)
      Delete consumer groups from the cluster.

      Unlike the bare Vert.x variant, this method ignores the Void result or any failure.

      Parameters:
      groupIds - the ids of the groups to delete
      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.deleteConsumerGroups(List)

    • deleteConsumerGroupOffsets

      @CheckReturnValue public io.smallrye.mutiny.Uni<Void> deleteConsumerGroupOffsets(String groupId, Set<io.vertx.kafka.client.common.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.

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Parameters:
      groupId - The group id of the group whose offsets will be deleted
      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.deleteConsumerGroupOffsets(String, Set)

    • deleteConsumerGroupOffsetsAndAwait

      public void deleteConsumerGroupOffsetsAndAwait(String groupId, Set<io.vertx.kafka.client.common.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.

      Unlike the bare Vert.x variant, this method returns a Void. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      groupId - The group id of the group whose offsets will be deleted
      See Also:
      • KafkaAdminClient.deleteConsumerGroupOffsets(String, Set)

    • deleteConsumerGroupOffsetsAndForget

      public KafkaAdminClient deleteConsumerGroupOffsetsAndForget(String groupId, Set<io.vertx.kafka.client.common.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.

      Unlike the bare Vert.x variant, this method ignores the Void result or any failure.

      Parameters:
      groupId - The group id of the group whose offsets will be deleted
      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.deleteConsumerGroupOffsets(String, Set)

    • describeAcls

      @CheckReturnValue public io.smallrye.mutiny.Uni<List<org.apache.kafka.common.acl.AclBinding>> describeAcls(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter)
      Describe the ACL rules.

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Parameters:
      aclBindingFilter - The filter to use.
      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.describeAcls(AclBindingFilter)

    • describeAclsAndAwait

      public List<org.apache.kafka.common.acl.AclBinding> describeAclsAndAwait(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter)
      Describe the ACL rules.

      Unlike the bare Vert.x variant, this method returns a List<org.apache.kafka.common.acl.AclBinding>. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      aclBindingFilter - The filter to use.
      Returns:
      The operation result
      See Also:
      • KafkaAdminClient.describeAcls(AclBindingFilter)

    • describeAclsAndForget

      public KafkaAdminClient describeAclsAndForget(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter)
      Describe the ACL rules.

      Unlike the bare Vert.x variant, this method ignores the List<org.apache.kafka.common.acl.AclBinding> result or any failure.

      Parameters:
      aclBindingFilter - The filter to use.
      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.describeAcls(AclBindingFilter)

    • createAcls

      @CheckReturnValue public io.smallrye.mutiny.Uni<List<org.apache.kafka.common.acl.AclBinding>> createAcls(List<org.apache.kafka.common.acl.AclBinding> aclBindings)
      Create the ACL rules.

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Parameters:
      aclBindings - The ACL to create.
      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.createAcls(List)

    • createAclsAndAwait

      public List<org.apache.kafka.common.acl.AclBinding> createAclsAndAwait(List<org.apache.kafka.common.acl.AclBinding> aclBindings)
      Create the ACL rules.

      Unlike the bare Vert.x variant, this method returns a List<org.apache.kafka.common.acl.AclBinding>. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      aclBindings - The ACL to create.
      Returns:
      The operation result
      See Also:
      • KafkaAdminClient.createAcls(List)

    • createAclsAndForget

      public KafkaAdminClient createAclsAndForget(List<org.apache.kafka.common.acl.AclBinding> aclBindings)
      Create the ACL rules.

      Unlike the bare Vert.x variant, this method ignores the List<org.apache.kafka.common.acl.AclBinding> result or any failure.

      Parameters:
      aclBindings - The ACL to create.
      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.createAcls(List)

    • deleteAcls

      @CheckReturnValue public io.smallrye.mutiny.Uni<List<org.apache.kafka.common.acl.AclBinding>> deleteAcls(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings)
      Delete the ACL rules.

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Parameters:
      aclBindings - The filter to delete matching ACLs.
      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.deleteAcls(List)

    • deleteAclsAndAwait

      public List<org.apache.kafka.common.acl.AclBinding> deleteAclsAndAwait(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings)
      Delete the ACL rules.

      Unlike the bare Vert.x variant, this method returns a List<org.apache.kafka.common.acl.AclBinding>. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      aclBindings - The filter to delete matching ACLs.
      Returns:
      The operation result
      See Also:
      • KafkaAdminClient.deleteAcls(List)

    • deleteAclsAndForget

      public KafkaAdminClient deleteAclsAndForget(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings)
      Delete the ACL rules.

      Unlike the bare Vert.x variant, this method ignores the List<org.apache.kafka.common.acl.AclBinding> result or any failure.

      Parameters:
      aclBindings - The filter to delete matching ACLs.
      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.deleteAcls(List)

    • close

      @CheckReturnValue public io.smallrye.mutiny.Uni<Void> close()
      Close the admin client

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.close()

    • closeAndAwait

      public void closeAndAwait()
      Close the admin client

      Unlike the bare Vert.x variant, this method returns a Void. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      See Also:
      • KafkaAdminClient.close()

    • closeAndForget

      public KafkaAdminClient closeAndForget()
      Close the admin client

      Unlike the bare Vert.x variant, this method ignores the Void result or any failure.

      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.close()

    • close

      @CheckReturnValue public io.smallrye.mutiny.Uni<Void> close(long timeout)
      Close the admin client

      Unlike the bare Vert.x variant, this method returns a Uni. The uni emits the result of the operation as item. If the operation fails, the uni emits the failure.

      Don't forget to subscribe on it to trigger the operation.

      Parameters:
      timeout - timeout to wait for closing
      Returns:
      A Uni representing the asynchronous result of this operation.
      See Also:
      • KafkaAdminClient.close(long)

    • closeAndAwait

      public void closeAndAwait(long timeout)
      Close the admin client

      Unlike the bare Vert.x variant, this method returns a Void. This method awaits indefinitely for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      timeout - timeout to wait for closing
      See Also:
      • KafkaAdminClient.close(long)

    • closeAndForget

      public KafkaAdminClient closeAndForget(long timeout)
      Close the admin client

      Unlike the bare Vert.x variant, this method ignores the Void result or any failure.

      Parameters:
      timeout - timeout to wait for closing
      Returns:
      The current instance to chain operations if needed.
      See Also:
      • KafkaAdminClient.close(long)

    • 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

    • newInstance

      public static KafkaAdminClient newInstance(io.vertx.kafka.admin.KafkaAdminClient delegate)
      Creates a new instance of the KafkaAdminClient.

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object