public interface KafkaAdminClient
| 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 |
alterConsumerGroupOffsets(String groupId,
Map<TopicPartition,OffsetAndMetadata> offsets,
Handler<AsyncResult<Void>> completionHandler)
Alter committed offsets for a set of partitions in a consumer group.
|
void |
close()
Close the admin client
|
void |
close(Handler<AsyncResult<Void>> completionHandler)
Close the admin client
|
void |
close(long timeout,
Handler<AsyncResult<Void>> completionHandler)
Close the admin client
|
static KafkaAdminClient |
create(Vertx vertx,
org.apache.kafka.clients.admin.AdminClient adminClient)
Create a new KafkaAdminClient instance
|
static KafkaAdminClient |
create(Vertx vertx,
Map<String,String> config)
Create a new KafkaAdminClient instance
|
static KafkaAdminClient |
create(Vertx vertx,
Properties config)
Create a new KafkaAdminClient instance
|
void |
createTopics(List<NewTopic> topics,
Handler<AsyncResult<Void>> completionHandler)
Creates a batch of new Kafka topics
|
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,
Handler<AsyncResult<Void>> completionHandler)
Delete consumer groups from the cluster.
|
void |
deleteTopics(List<String> topicNames,
Handler<AsyncResult<Void>> completionHandler)
Deletes a batch of Kafka topics
|
void |
describeCluster(Handler<AsyncResult<ClusterDescription>> completionHandler)
Describe the nodes in the cluster with the default options
|
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.
|
default void |
listConsumerGroupOffsets(String groupId,
Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
List the consumer group offsets available in the cluster.
|
void |
listConsumerGroupOffsets(String groupId,
ListConsumerGroupOffsetsOptions options,
Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
List the consumer group offsets available in the cluster.
|
void |
listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)
Get the the consumer groups available in the cluster with the default options
|
void |
listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets,
Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler)
List the offsets available for a set of partitions.
|
void |
listTopics(Handler<AsyncResult<Set<String>>> completionHandler)
List the topics available in the cluster with the default options.
|
static KafkaAdminClient create(Vertx vertx, org.apache.kafka.clients.admin.AdminClient adminClient)
vertx - Vert.x instance to useadminClient - Kafka native Admin client instancestatic KafkaAdminClient create(Vertx vertx, Map<String,String> config)
vertx - Vert.x instance to useconfig - Kafka admin client configurationstatic KafkaAdminClient create(Vertx vertx, Properties config)
vertx - Vert.x instance to useconfig - Kafka admin client configurationvoid listTopics(Handler<AsyncResult<Set<String>>> completionHandler)
completionHandler - handler called on operation completed with the topics setvoid 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 descriptionsvoid createTopics(List<NewTopic> topics, Handler<AsyncResult<Void>> completionHandler)
topics - topics to createcompletionHandler - handler called on operation completedvoid deleteTopics(List<String> topicNames, Handler<AsyncResult<Void>> completionHandler)
topicNames - the names of the topics to deletecompletionHandler - handler called on operation completedvoid describeConfigs(List<ConfigResource> configResources, Handler<AsyncResult<Map<ConfigResource,Config>>> completionHandler)
configResources - the resources (topic and broker resource types are currently supported)completionHandler - handler called on operation completed with the configurationsvoid alterConfigs(Map<ConfigResource,Config> configs, Handler<AsyncResult<Void>> completionHandler)
configs - The resources with their configs (topic is the only resource type with configs that can be updated currently)completionHandler - handler called on operation completedvoid listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)
completionHandler - handler called on operation completed with the consumer groups idsvoid 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 descriptionsvoid close()
void describeCluster(Handler<AsyncResult<ClusterDescription>> completionHandler)
completionHandler - handler called on operation completed with the cluster descriptionvoid deleteConsumerGroups(List<String> groupIds, Handler<AsyncResult<Void>> completionHandler)
groupIds - the ids of the groups to deletecompletionHandler - handler called on operation completedvoid listConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsOptions options, Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
groupId - The group id of the group whose offsets will be listedoptions - The options to use when listing the consumer group offsets.completionHandler - handler called on operation completed with the consumer groups offsetsdefault void listConsumerGroupOffsets(String groupId, Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
groupId - The group id of the group whose offsets will be listedcompletionHandler - handler called on operation completed with the consumer groups offsetsvoid deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions, Handler<AsyncResult<Void>> completionHandler)
groupId - The group id of the group whose offsets will be listedpartitions - The set of partitions in the consumer group whose offsets will be deletedvoid alterConsumerGroupOffsets(String groupId, Map<TopicPartition,OffsetAndMetadata> offsets, Handler<AsyncResult<Void>> completionHandler)
groupId - The group id of the group whose offsets will be alteredoffsets - The map of offsets in the consumer group which will be alteredvoid listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets, Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler)
topicPartitionOffsets - The options to use when listing the partition offsets.completionHandler - handler called on operation completed with the partition offsetsvoid close(Handler<AsyncResult<Void>> completionHandler)
completionHandler - handler called on operation completedvoid close(long timeout,
Handler<AsyncResult<Void>> completionHandler)
timeout - timeout to wait for closingcompletionHandler - handler called on operation completedCopyright © 2021 Eclipse. All rights reserved.