Uses of Class
io.vertx.mutiny.kafka.admin.KafkaAdminClient

Packages that use KafkaAdminClient

Package	Description
io.vertx.mutiny.kafka.admin

Uses of KafkaAdminClient in io.vertx.mutiny.kafka.admin

Fields in io.vertx.mutiny.kafka.admin with type parameters of type KafkaAdminClient

Modifier and Type	Field	Description
static final TypeArg<KafkaAdminClient>	KafkaAdminClient.__TYPE_ARG

Methods in io.vertx.mutiny.kafka.admin that return KafkaAdminClient

Modifier and Type	Method	Description
KafkaAdminClient	KafkaAdminClient.closeAndForget()	Close the admin client
KafkaAdminClient	KafkaAdminClient.closeAndForget(long timeout)	Close the admin client
static KafkaAdminClient	KafkaAdminClient.create(Vertx vertx, Map<String,String> config)	Create a new KafkaAdminClient instance
KafkaAdminClient	KafkaAdminClient.createAclsAndForget(List<org.apache.kafka.common.acl.AclBinding> aclBindings)	Create the ACL rules.
KafkaAdminClient	KafkaAdminClient.createPartitionsAndForget(Map<String,io.vertx.kafka.admin.NewPartitions> partitions)	Creates a batch of new partitions in the Kafka topic
KafkaAdminClient	KafkaAdminClient.createTopicsAndForget(List<io.vertx.kafka.admin.NewTopic> topics)	Creates a batch of new Kafka topics
KafkaAdminClient	KafkaAdminClient.deleteAclsAndForget(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings)	Delete the ACL rules.
KafkaAdminClient	KafkaAdminClient.deleteConsumerGroupOffsetsAndForget(String groupId, Set<io.vertx.kafka.client.common.TopicPartition> partitions)	Delete committed offsets for a set of partitions in a consumer group.
KafkaAdminClient	KafkaAdminClient.deleteConsumerGroupsAndForget(List<String> groupIds)	Delete consumer groups from the cluster.
KafkaAdminClient	KafkaAdminClient.deleteTopicsAndForget(List<String> topicNames)	Deletes a batch of Kafka topics
KafkaAdminClient	KafkaAdminClient.describeAclsAndForget(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter)	Describe the ACL rules.
KafkaAdminClient	KafkaAdminClient.describeClusterAndForget()	Describe the nodes in the cluster with the default options
KafkaAdminClient	KafkaAdminClient.describeClusterAndForget(io.vertx.kafka.admin.DescribeClusterOptions options)	Like describeCluster() but allows customized options.
KafkaAdminClient	KafkaAdminClient.describeConsumerGroupsAndForget(List<String> groupIds)	Describe some group ids in the cluster, with the default options
KafkaAdminClient	KafkaAdminClient.describeConsumerGroupsAndForget(List<String> groupIds, io.vertx.kafka.admin.DescribeConsumerGroupsOptions options)	Like describeConsumerGroups(List) but allows customized options
KafkaAdminClient	KafkaAdminClient.describeTopicsAndForget(List<String> topicNames)	Describe some topics in the cluster, with the default options.
KafkaAdminClient	KafkaAdminClient.describeTopicsAndForget(List<String> topicNames, io.vertx.kafka.admin.DescribeTopicsOptions options)	Like describeTopics(List) but allows for customised otions
KafkaAdminClient	KafkaAdminClient.listConsumerGroupsAndForget()	Get the the consumer groups available in the cluster with the default options
KafkaAdminClient	KafkaAdminClient.listTopicsAndForget()	List the topics available in the cluster with the default options.
static KafkaAdminClient	KafkaAdminClient.newInstance(io.vertx.kafka.admin.KafkaAdminClient delegate)	Creates a new instance of the KafkaAdminClient.