public class KafkaAdminClientImpl extends Object implements KafkaAdminClient
| Constructor and Description |
|---|
KafkaAdminClientImpl(Vertx vertx,
org.apache.kafka.clients.admin.AdminClient adminClient) |
| Modifier and Type | Method and Description |
|---|---|
void |
alterConfigs(Map<ConfigResource,Config> configs,
Handler<AsyncResult<Void>> completionHandler)
Update the configuration for the specified resources with the default options
|
void |
createTopics(List<NewTopic> topics,
Handler<AsyncResult<Void>> completionHandler)
Creates a batch of new Kafka topics
|
void |
deleteTopics(List<String> topicNames,
Handler<AsyncResult<Void>> completionHandler)
Deletes a batch of Kafka topics
|
void |
describeConfigs(List<ConfigResource> configResources,
Handler<AsyncResult<Map<ConfigResource,Config>>> completionHandler)
Get the configuration for the specified resources with the default options
|
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,
Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
Describe some topics 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(Handler<AsyncResult<Set<String>>> completionHandler)
List the topics available in the cluster with the default options.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcreate, create, createpublic KafkaAdminClientImpl(Vertx vertx, org.apache.kafka.clients.admin.AdminClient adminClient)
public void describeTopics(List<String> topicNames, Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
KafkaAdminClientdescribeTopics in interface KafkaAdminClienttopicNames - the names of the topics to describecompletionHandler - handler called on operation completed with the topics descriptionspublic void listTopics(Handler<AsyncResult<Set<String>>> completionHandler)
KafkaAdminClientlistTopics in interface KafkaAdminClientcompletionHandler - handler called on operation completed with the topics setpublic void createTopics(List<NewTopic> topics, Handler<AsyncResult<Void>> completionHandler)
KafkaAdminClientcreateTopics in interface KafkaAdminClienttopics - topics to createcompletionHandler - handler called on operation completedpublic void deleteTopics(List<String> topicNames, Handler<AsyncResult<Void>> completionHandler)
KafkaAdminClientdeleteTopics in interface KafkaAdminClienttopicNames - the names of the topics to deletecompletionHandler - handler called on operation completedpublic void describeConfigs(List<ConfigResource> configResources, Handler<AsyncResult<Map<ConfigResource,Config>>> completionHandler)
KafkaAdminClientdescribeConfigs in interface KafkaAdminClientconfigResources - the resources (topic and broker resource types are currently supported)completionHandler - handler called on operation completed with the configurationspublic void alterConfigs(Map<ConfigResource,Config> configs, Handler<AsyncResult<Void>> completionHandler)
KafkaAdminClientalterConfigs in interface KafkaAdminClientconfigs - The resources with their configs (topic is the only resource type with configs that can be updated currently)completionHandler - handler called on operation completedpublic void listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)
KafkaAdminClientlistConsumerGroups in interface KafkaAdminClientcompletionHandler - handler called on operation completed with the consumer groups idspublic void describeConsumerGroups(List<String> groupIds, Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
KafkaAdminClientdescribeConsumerGroups in interface KafkaAdminClientgroupIds - the ids of the groups to describecompletionHandler - handler called on operation completed with the consumer groups descriptionsCopyright © 2020. All rights reserved.