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 |
|---|---|
Future<Void> |
alterConfigs(Map<ConfigResource,Config> configs)
Like
KafkaAdminClient.alterConfigs(Map, Handler) but returns a Future of the asynchronous result |
void |
alterConfigs(Map<ConfigResource,Config> configs,
Handler<AsyncResult<Void>> completionHandler)
Update the configuration for the specified resources with the default options
|
Future<Void> |
alterConsumerGroupOffsets(String groupId,
Map<TopicPartition,OffsetAndMetadata> offsets)
Like
KafkaAdminClient.alterConsumerGroupOffsets(String, Map, Handler) but returns a Future of the asynchronous result |
void |
alterConsumerGroupOffsets(String groupId,
Map<TopicPartition,OffsetAndMetadata> offsets,
Handler<AsyncResult<Void>> completionHandler)
Alter committed offsets for a set of partitions in a consumer group.
|
Future<Void> |
close()
Like
KafkaAdminClient.close(Handler) but returns a Future of the asynchronous result |
void |
close(Handler<AsyncResult<Void>> handler)
Close the admin client
|
Future<Void> |
close(long timeout)
Like
KafkaAdminClient.close(long, Handler) but returns a Future of the asynchronous result |
void |
close(long timeout,
Handler<AsyncResult<Void>> handler)
Close the admin client
|
Future<Void> |
createTopics(List<NewTopic> topics)
Like
KafkaAdminClient.createTopics(List, Handler) but returns a Future of the asynchronous result |
void |
createTopics(List<NewTopic> topics,
Handler<AsyncResult<Void>> completionHandler)
Creates a batch of new Kafka topics
|
Future<Void> |
deleteConsumerGroupOffsets(String groupId,
Set<TopicPartition> partitions)
Like
KafkaAdminClient.deleteConsumerGroupOffsets(String, Set, Handler) but returns a Future of the asynchronous result |
void |
deleteConsumerGroupOffsets(String groupId,
Set<TopicPartition> partitions,
Handler<AsyncResult<Void>> completionHandler)
Delete committed offsets for a set of partitions in a consumer group.
|
Future<Void> |
deleteConsumerGroups(List<String> groupIds)
Like
KafkaAdminClient.deleteConsumerGroups(List, Handler) but returns a Future of the asynchronous result |
void |
deleteConsumerGroups(List<String> groupIds,
Handler<AsyncResult<Void>> completionHandler)
Delete consumer groups from the cluster.
|
Future<Void> |
deleteTopics(List<String> topicNames)
Like
KafkaAdminClient.deleteTopics(List, Handler) but returns a Future of the asynchronous result |
void |
deleteTopics(List<String> topicNames,
Handler<AsyncResult<Void>> completionHandler)
Deletes a batch of Kafka topics
|
Future<ClusterDescription> |
describeCluster()
Like
KafkaAdminClient.describeCluster(Handler) but returns a Future of the asynchronous result |
void |
describeCluster(Handler<AsyncResult<ClusterDescription>> completionHandler)
Describe the nodes in the cluster with the default options
|
Future<Map<ConfigResource,Config>> |
describeConfigs(List<ConfigResource> configResources)
Like
KafkaAdminClient.describeConfigs(List, Handler) but returns a Future of the asynchronous result |
void |
describeConfigs(List<ConfigResource> configResources,
Handler<AsyncResult<Map<ConfigResource,Config>>> completionHandler)
Get the configuration for the specified resources with the default options
|
Future<Map<String,ConsumerGroupDescription>> |
describeConsumerGroups(List<String> groupIds)
Like
KafkaAdminClient.describeConsumerGroups(List, Handler) but returns a Future of the asynchronous result |
void |
describeConsumerGroups(List<String> groupIds,
Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
Describe some group ids in the cluster, with the default options
|
Future<Map<String,TopicDescription>> |
describeTopics(List<String> topicNames)
Like
KafkaAdminClient.describeTopics(List, Handler) but returns a Future of the asynchronous result |
void |
describeTopics(List<String> topicNames,
Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
Describe some topics in the cluster, with the default options.
|
Future<Map<TopicPartition,OffsetAndMetadata>> |
listConsumerGroupOffsets(String groupId,
ListConsumerGroupOffsetsOptions options)
Like
KafkaAdminClient.listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions, Handler) but returns a Future of the asynchronous result |
void |
listConsumerGroupOffsets(String groupId,
ListConsumerGroupOffsetsOptions options,
Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
List the consumer group offsets available in the cluster.
|
Future<List<ConsumerGroupListing>> |
listConsumerGroups()
Like
KafkaAdminClient.listConsumerGroups(Handler) but returns a Future of the asynchronous result |
void |
listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)
Get the the consumer groups available in the cluster with the default options
|
Future<Map<TopicPartition,ListOffsetsResultInfo>> |
listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets)
Like
#listOffsets(Map but returns a Future of the asynchronous result |
void |
listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets,
Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler)
List the offsets available for a set of partitions.
|
Future<Set<String>> |
listTopics()
Like
KafkaAdminClient.listTopics(Handler) but returns a Future of the asynchronous result |
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, create, listConsumerGroupOffsets, listConsumerGroupOffsetspublic 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 Future<Map<String,TopicDescription>> describeTopics(List<String> topicNames)
KafkaAdminClientKafkaAdminClient.describeTopics(List, Handler) but returns a Future of the asynchronous resultdescribeTopics in interface KafkaAdminClientpublic void listTopics(Handler<AsyncResult<Set<String>>> completionHandler)
KafkaAdminClientlistTopics in interface KafkaAdminClientcompletionHandler - handler called on operation completed with the topics setpublic Future<Set<String>> listTopics()
KafkaAdminClientKafkaAdminClient.listTopics(Handler) but returns a Future of the asynchronous resultlistTopics in interface KafkaAdminClientpublic void createTopics(List<NewTopic> topics, Handler<AsyncResult<Void>> completionHandler)
KafkaAdminClientcreateTopics in interface KafkaAdminClienttopics - topics to createcompletionHandler - handler called on operation completedpublic Future<Void> createTopics(List<NewTopic> topics)
KafkaAdminClientKafkaAdminClient.createTopics(List, Handler) but returns a Future of the asynchronous resultcreateTopics in interface KafkaAdminClientpublic 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 Future<Void> deleteTopics(List<String> topicNames)
KafkaAdminClientKafkaAdminClient.deleteTopics(List, Handler) but returns a Future of the asynchronous resultdeleteTopics in interface KafkaAdminClientpublic 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 Future<Map<ConfigResource,Config>> describeConfigs(List<ConfigResource> configResources)
KafkaAdminClientKafkaAdminClient.describeConfigs(List, Handler) but returns a Future of the asynchronous resultdescribeConfigs in interface KafkaAdminClientpublic 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 Future<Void> alterConfigs(Map<ConfigResource,Config> configs)
KafkaAdminClientKafkaAdminClient.alterConfigs(Map, Handler) but returns a Future of the asynchronous resultalterConfigs in interface KafkaAdminClientpublic void listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)
KafkaAdminClientlistConsumerGroups in interface KafkaAdminClientcompletionHandler - handler called on operation completed with the consumer groups idspublic Future<List<ConsumerGroupListing>> listConsumerGroups()
KafkaAdminClientKafkaAdminClient.listConsumerGroups(Handler) but returns a Future of the asynchronous resultlistConsumerGroups in interface KafkaAdminClientpublic 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 descriptionspublic Future<Map<String,ConsumerGroupDescription>> describeConsumerGroups(List<String> groupIds)
KafkaAdminClientKafkaAdminClient.describeConsumerGroups(List, Handler) but returns a Future of the asynchronous resultdescribeConsumerGroups in interface KafkaAdminClientpublic void listConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsOptions options, Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
KafkaAdminClientlistConsumerGroupOffsets in interface KafkaAdminClientgroupId - 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 offsetspublic Future<Map<TopicPartition,OffsetAndMetadata>> listConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsOptions options)
KafkaAdminClientKafkaAdminClient.listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions, Handler) but returns a Future of the asynchronous resultlistConsumerGroupOffsets in interface KafkaAdminClientpublic void deleteConsumerGroups(List<String> groupIds, Handler<AsyncResult<Void>> completionHandler)
KafkaAdminClientdeleteConsumerGroups in interface KafkaAdminClientgroupIds - the ids of the groups to deletecompletionHandler - handler called on operation completedpublic Future<Void> deleteConsumerGroups(List<String> groupIds)
KafkaAdminClientKafkaAdminClient.deleteConsumerGroups(List, Handler) but returns a Future of the asynchronous resultdeleteConsumerGroups in interface KafkaAdminClientpublic void alterConsumerGroupOffsets(String groupId, Map<TopicPartition,OffsetAndMetadata> offsets, Handler<AsyncResult<Void>> completionHandler)
KafkaAdminClientalterConsumerGroupOffsets in interface KafkaAdminClientgroupId - The group id of the group whose offsets will be alteredoffsets - The map of offsets in the consumer group which will be alteredpublic Future<Void> alterConsumerGroupOffsets(String groupId, Map<TopicPartition,OffsetAndMetadata> offsets)
KafkaAdminClientKafkaAdminClient.alterConsumerGroupOffsets(String, Map, Handler) but returns a Future of the asynchronous resultalterConsumerGroupOffsets in interface KafkaAdminClientpublic void deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions, Handler<AsyncResult<Void>> completionHandler)
KafkaAdminClientdeleteConsumerGroupOffsets in interface KafkaAdminClientgroupId - The group id of the group whose offsets will be deletedpartitions - The set of partitions in the consumer group whose offsets will be deletedpublic Future<Void> deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)
KafkaAdminClientKafkaAdminClient.deleteConsumerGroupOffsets(String, Set, Handler) but returns a Future of the asynchronous resultdeleteConsumerGroupOffsets in interface KafkaAdminClientpublic void describeCluster(Handler<AsyncResult<ClusterDescription>> completionHandler)
KafkaAdminClientdescribeCluster in interface KafkaAdminClientcompletionHandler - handler called on operation completed with the cluster descriptionpublic Future<ClusterDescription> describeCluster()
KafkaAdminClientKafkaAdminClient.describeCluster(Handler) but returns a Future of the asynchronous resultdescribeCluster in interface KafkaAdminClientpublic void listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets, Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler)
KafkaAdminClientlistOffsets in interface KafkaAdminClienttopicPartitionOffsets - The options to use when listing the partition offsets.completionHandler - handler called on operation completed with the partition offsetspublic Future<Map<TopicPartition,ListOffsetsResultInfo>> listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets)
KafkaAdminClient#listOffsets(Map, Handler) but returns a Future of the asynchronous resultlistOffsets in interface KafkaAdminClientpublic Future<Void> close()
KafkaAdminClientKafkaAdminClient.close(Handler) but returns a Future of the asynchronous resultclose in interface KafkaAdminClientpublic Future<Void> close(long timeout)
KafkaAdminClientKafkaAdminClient.close(long, Handler) but returns a Future of the asynchronous resultclose in interface KafkaAdminClientpublic void close(Handler<AsyncResult<Void>> handler)
KafkaAdminClientclose in interface KafkaAdminClienthandler - a Handler completed with the operation resultpublic void close(long timeout,
Handler<AsyncResult<Void>> handler)
KafkaAdminClientclose in interface KafkaAdminClienttimeout - timeout to wait for closinghandler - a Handler completed with the operation resultCopyright © 2021. All rights reserved.