Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<KafkaAdminClient> |
__TYPE_ARG |
Constructor and Description |
---|
KafkaAdminClient(KafkaAdminClient delegate) |
KafkaAdminClient(Object delegate) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the admin client
|
void |
close(Handler<AsyncResult<Void>> handler)
Close the admin client
|
void |
close(long timeout)
Close the admin client
|
void |
close(long timeout,
Handler<AsyncResult<Void>> handler)
Close the admin client
|
static KafkaAdminClient |
create(Vertx vertx,
Map<String,String> config)
Create a new KafkaAdminClient instance
|
void |
createAcls(List<org.apache.kafka.common.acl.AclBinding> aclBindings)
Create the ACL rules.
|
void |
createAcls(List<org.apache.kafka.common.acl.AclBinding> aclBindings,
Handler<AsyncResult<List<org.apache.kafka.common.acl.AclBinding>>> completionHandler)
Create the ACL rules.
|
void |
createPartitions(Map<String,NewPartitions> partitions)
Creates a batch of new partitions in the Kafka topic
|
void |
createPartitions(Map<String,NewPartitions> partitions,
Handler<AsyncResult<Void>> completionHandler)
Creates a batch of new partitions in the Kafka topic
|
void |
createTopics(List<NewTopic> topics)
Creates a batch of new Kafka topics
|
void |
createTopics(List<NewTopic> topics,
Handler<AsyncResult<Void>> completionHandler)
Creates a batch of new Kafka topics
|
void |
deleteAcls(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings)
Delete the ACL rules.
|
void |
deleteAcls(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings,
Handler<AsyncResult<List<org.apache.kafka.common.acl.AclBinding>>> completionHandler)
Delete the ACL rules.
|
void |
deleteConsumerGroupOffsets(String groupId,
Set<TopicPartition> partitions)
Delete committed offsets for a set of partitions in a consumer group.
|
void |
deleteConsumerGroupOffsets(String groupId,
Set<TopicPartition> partitions,
Handler<AsyncResult<Void>> completionHandler)
Delete committed offsets for a set of partitions in a consumer group.
|
void |
deleteConsumerGroups(List<String> groupIds)
Delete consumer groups from the cluster.
|
void |
deleteConsumerGroups(List<String> groupIds,
Handler<AsyncResult<Void>> completionHandler)
Delete consumer groups from the cluster.
|
void |
deleteTopics(List<String> topicNames)
Deletes a batch of Kafka topics
|
void |
deleteTopics(List<String> topicNames,
Handler<AsyncResult<Void>> completionHandler)
Deletes a batch of Kafka topics
|
void |
describeAcls(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter)
Describe the ACL rules.
|
void |
describeAcls(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter,
Handler<AsyncResult<List<org.apache.kafka.common.acl.AclBinding>>> completionHandler)
Describe the ACL rules.
|
void |
describeCluster()
Describe the nodes in the cluster with the default options
|
void |
describeCluster(DescribeClusterOptions options)
Like
describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>) but allows customized options. |
void |
describeCluster(DescribeClusterOptions options,
Handler<AsyncResult<ClusterDescription>> completionHandler)
Like
describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>) but allows customized options. |
void |
describeCluster(Handler<AsyncResult<ClusterDescription>> completionHandler)
Describe the nodes in the cluster with the default options
|
void |
describeConsumerGroups(List<String> groupIds)
Describe some group ids in the cluster, with the default options
|
void |
describeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options)
|
void |
describeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options,
Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
|
void |
describeConsumerGroups(List<String> groupIds,
Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
Describe some group ids in the cluster, with the default options
|
void |
describeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.
|
void |
describeTopics(List<String> topicNames,
DescribeTopicsOptions options)
|
void |
describeTopics(List<String> topicNames,
DescribeTopicsOptions options,
Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
|
void |
describeTopics(List<String> topicNames,
Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
Describe some topics in the cluster, with the default options.
|
boolean |
equals(Object o) |
KafkaAdminClient |
getDelegate() |
int |
hashCode() |
void |
listConsumerGroups()
Get the the consumer groups available in the cluster with the default options
|
void |
listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)
Get the the consumer groups available in the cluster with the default options
|
void |
listTopics()
List the topics available in the cluster with the default options.
|
void |
listTopics(Handler<AsyncResult<Set<String>>> completionHandler)
List the topics available in the cluster with the default options.
|
static KafkaAdminClient |
newInstance(KafkaAdminClient arg) |
Completable |
rxClose()
Close the admin client
|
Completable |
rxClose(long timeout)
Close the admin client
|
Single<List<org.apache.kafka.common.acl.AclBinding>> |
rxCreateAcls(List<org.apache.kafka.common.acl.AclBinding> aclBindings)
Create the ACL rules.
|
Completable |
rxCreatePartitions(Map<String,NewPartitions> partitions)
Creates a batch of new partitions in the Kafka topic
|
Completable |
rxCreateTopics(List<NewTopic> topics)
Creates a batch of new Kafka topics
|
Single<List<org.apache.kafka.common.acl.AclBinding>> |
rxDeleteAcls(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings)
Delete the ACL rules.
|
Completable |
rxDeleteConsumerGroupOffsets(String groupId,
Set<TopicPartition> partitions)
Delete committed offsets for a set of partitions in a consumer group.
|
Completable |
rxDeleteConsumerGroups(List<String> groupIds)
Delete consumer groups from the cluster.
|
Completable |
rxDeleteTopics(List<String> topicNames)
Deletes a batch of Kafka topics
|
Single<List<org.apache.kafka.common.acl.AclBinding>> |
rxDescribeAcls(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter)
Describe the ACL rules.
|
Single<ClusterDescription> |
rxDescribeCluster()
Describe the nodes in the cluster with the default options
|
Single<ClusterDescription> |
rxDescribeCluster(DescribeClusterOptions options)
Like
describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>) but allows customized options. |
Single<Map<String,ConsumerGroupDescription>> |
rxDescribeConsumerGroups(List<String> groupIds)
Describe some group ids in the cluster, with the default options
|
Single<Map<String,ConsumerGroupDescription>> |
rxDescribeConsumerGroups(List<String> groupIds,
DescribeConsumerGroupsOptions options)
|
Single<Map<String,TopicDescription>> |
rxDescribeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.
|
Single<Map<String,TopicDescription>> |
rxDescribeTopics(List<String> topicNames,
DescribeTopicsOptions options)
|
Single<List<ConsumerGroupListing>> |
rxListConsumerGroups()
Get the the consumer groups available in the cluster with the default options
|
Single<Set<String>> |
rxListTopics()
List the topics available in the cluster with the default options.
|
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<KafkaAdminClient> __TYPE_ARG
public KafkaAdminClient(KafkaAdminClient delegate)
public KafkaAdminClient(Object delegate)
public KafkaAdminClient getDelegate()
public static KafkaAdminClient create(Vertx vertx, Map<String,String> config)
vertx
- Vert.x instance to useconfig
- Kafka admin client configurationpublic void listTopics(Handler<AsyncResult<Set<String>>> completionHandler)
completionHandler
- handler called on operation completed with the topics setpublic void listTopics()
public Single<Set<String>> rxListTopics()
public void describeTopics(List<String> topicNames, Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
topicNames
- the names of the topics to describecompletionHandler
- handler called on operation completed with the topics descriptionspublic void describeTopics(List<String> topicNames)
topicNames
- the names of the topics to describepublic Single<Map<String,TopicDescription>> rxDescribeTopics(List<String> topicNames)
topicNames
- the names of the topics to describepublic void describeTopics(List<String> topicNames, DescribeTopicsOptions options, Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
describeTopics(java.util.List<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<java.lang.String, io.vertx.kafka.admin.TopicDescription>>>)
but allows for customised otionstopicNames
- options
- completionHandler
- public void describeTopics(List<String> topicNames, DescribeTopicsOptions options)
describeTopics(java.util.List<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<java.lang.String, io.vertx.kafka.admin.TopicDescription>>>)
but allows for customised otionstopicNames
- options
- public Single<Map<String,TopicDescription>> rxDescribeTopics(List<String> topicNames, DescribeTopicsOptions options)
describeTopics(java.util.List<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<java.lang.String, io.vertx.kafka.admin.TopicDescription>>>)
but allows for customised otionstopicNames
- options
- public void createTopics(List<NewTopic> topics, Handler<AsyncResult<Void>> completionHandler)
topics
- topics to createcompletionHandler
- handler called on operation completedpublic void createTopics(List<NewTopic> topics)
topics
- topics to createpublic Completable rxCreateTopics(List<NewTopic> topics)
topics
- topics to createpublic void deleteTopics(List<String> topicNames, Handler<AsyncResult<Void>> completionHandler)
topicNames
- the names of the topics to deletecompletionHandler
- handler called on operation completedpublic void deleteTopics(List<String> topicNames)
topicNames
- the names of the topics to deletepublic Completable rxDeleteTopics(List<String> topicNames)
topicNames
- the names of the topics to deletepublic void createPartitions(Map<String,NewPartitions> partitions, Handler<AsyncResult<Void>> completionHandler)
partitions
- partitions to createcompletionHandler
- handler called on operation completedpublic void createPartitions(Map<String,NewPartitions> partitions)
partitions
- partitions to createpublic Completable rxCreatePartitions(Map<String,NewPartitions> partitions)
partitions
- partitions to createpublic void listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)
completionHandler
- handler called on operation completed with the consumer groups idspublic void listConsumerGroups()
public Single<List<ConsumerGroupListing>> rxListConsumerGroups()
public void describeConsumerGroups(List<String> groupIds, Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
groupIds
- the ids of the groups to describecompletionHandler
- handler called on operation completed with the consumer groups descriptionspublic void describeConsumerGroups(List<String> groupIds)
groupIds
- the ids of the groups to describepublic Single<Map<String,ConsumerGroupDescription>> rxDescribeConsumerGroups(List<String> groupIds)
groupIds
- the ids of the groups to describepublic void describeConsumerGroups(List<String> groupIds, DescribeConsumerGroupsOptions options, Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
describeConsumerGroups(java.util.List<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<java.lang.String, io.vertx.kafka.admin.ConsumerGroupDescription>>>)
but allows customized optionsgroupIds
- options
- completionHandler
- public void describeConsumerGroups(List<String> groupIds, DescribeConsumerGroupsOptions options)
describeConsumerGroups(java.util.List<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<java.lang.String, io.vertx.kafka.admin.ConsumerGroupDescription>>>)
but allows customized optionsgroupIds
- options
- public Single<Map<String,ConsumerGroupDescription>> rxDescribeConsumerGroups(List<String> groupIds, DescribeConsumerGroupsOptions options)
describeConsumerGroups(java.util.List<java.lang.String>, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.Map<java.lang.String, io.vertx.kafka.admin.ConsumerGroupDescription>>>)
but allows customized optionsgroupIds
- options
- public void describeCluster(Handler<AsyncResult<ClusterDescription>> completionHandler)
completionHandler
- handler called on operation completed with the cluster descriptionpublic void describeCluster()
public Single<ClusterDescription> rxDescribeCluster()
public void describeCluster(DescribeClusterOptions options, Handler<AsyncResult<ClusterDescription>> completionHandler)
describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>)
but allows customized options.options
- completionHandler
- public void describeCluster(DescribeClusterOptions options)
describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>)
but allows customized options.options
- public Single<ClusterDescription> rxDescribeCluster(DescribeClusterOptions options)
describeCluster(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.kafka.admin.ClusterDescription>>)
but allows customized options.options
- public void deleteConsumerGroups(List<String> groupIds, Handler<AsyncResult<Void>> completionHandler)
groupIds
- the ids of the groups to deletecompletionHandler
- handler called on operation completedpublic void deleteConsumerGroups(List<String> groupIds)
groupIds
- the ids of the groups to deletepublic Completable rxDeleteConsumerGroups(List<String> groupIds)
groupIds
- the ids of the groups to deletepublic void deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions, Handler<AsyncResult<Void>> completionHandler)
groupId
- The group id of the group whose offsets will be deletedpartitions
- The set of partitions in the consumer group whose offsets will be deletedcompletionHandler
- public void deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)
groupId
- The group id of the group whose offsets will be deletedpartitions
- The set of partitions in the consumer group whose offsets will be deletedpublic Completable rxDeleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)
groupId
- The group id of the group whose offsets will be deletedpartitions
- The set of partitions in the consumer group whose offsets will be deletedpublic void close(Handler<AsyncResult<Void>> handler)
handler
- a Handler
completed with the operation resultpublic void close()
public Completable rxClose()
public void close(long timeout, Handler<AsyncResult<Void>> handler)
timeout
- timeout to wait for closinghandler
- a Handler
completed with the operation resultpublic void close(long timeout)
timeout
- timeout to wait for closingpublic Completable rxClose(long timeout)
timeout
- timeout to wait for closingpublic void describeAcls(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter, Handler<AsyncResult<List<org.apache.kafka.common.acl.AclBinding>>> completionHandler)
aclBindingFilter
- The filter to use.completionHandler
- handler called on operation completed with the ACL description result.public void describeAcls(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter)
aclBindingFilter
- The filter to use.public Single<List<org.apache.kafka.common.acl.AclBinding>> rxDescribeAcls(org.apache.kafka.common.acl.AclBindingFilter aclBindingFilter)
aclBindingFilter
- The filter to use.public void createAcls(List<org.apache.kafka.common.acl.AclBinding> aclBindings, Handler<AsyncResult<List<org.apache.kafka.common.acl.AclBinding>>> completionHandler)
aclBindings
- The ACL to create.completionHandler
- handler called on operation completed with the ACL creation result.public void createAcls(List<org.apache.kafka.common.acl.AclBinding> aclBindings)
aclBindings
- The ACL to create.public Single<List<org.apache.kafka.common.acl.AclBinding>> rxCreateAcls(List<org.apache.kafka.common.acl.AclBinding> aclBindings)
aclBindings
- The ACL to create.public void deleteAcls(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings, Handler<AsyncResult<List<org.apache.kafka.common.acl.AclBinding>>> completionHandler)
aclBindings
- The filter to delete matching ACLs.completionHandler
- handler called on operation completed with the ACL deletion result.public void deleteAcls(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings)
aclBindings
- The filter to delete matching ACLs.public Single<List<org.apache.kafka.common.acl.AclBinding>> rxDeleteAcls(List<org.apache.kafka.common.acl.AclBindingFilter> aclBindings)
aclBindings
- The filter to delete matching ACLs.public static KafkaAdminClient newInstance(KafkaAdminClient arg)
Copyright © 2023 Eclipse. All rights reserved.