new KafkaAdminClient()
Vert.x Kafka Admin client implementation
Methods
createTopics(topics, completionHandler)
Creates a batch of new Kafka topics
Parameters:
| Name | Type | Description |
|---|---|---|
topics |
Array.<Object> | topics to create |
completionHandler |
function | handler called on operation completed |
deleteTopics(topicNames, completionHandler)
Deletes a batch of Kafka topics
Parameters:
| Name | Type | Description |
|---|---|---|
topicNames |
Array.<string> | the names of the topics to delete |
completionHandler |
function | handler called on operation completed |
describeConsumerGroups(groupIds, completionHandler)
Describe some group ids in the cluster, with the default options
Parameters:
| Name | Type | Description |
|---|---|---|
groupIds |
Array.<string> | the ids of the groups to describe |
completionHandler |
function | handler called on operation completed with the consumer groups descriptions |
describeTopics(topicNames, completionHandler)
Describe some topics in the cluster, with the default options.
Parameters:
| Name | Type | Description |
|---|---|---|
topicNames |
Array.<string> | the names of the topics to describe |
completionHandler |
function | handler called on operation completed with the topics descriptions |
listConsumerGroups(completionHandler)
Get the the consumer groups available in the cluster with the default options
Parameters:
| Name | Type | Description |
|---|---|---|
completionHandler |
function | handler called on operation completed with the consumer groups ids |
listTopics(completionHandler)
List the topics available in the cluster with the default options.
Parameters:
| Name | Type | Description |
|---|---|---|
completionHandler |
function | handler called on operation completed with the topics set |