Class: KafkaAdminClient

vertx-kafka-client-js/kafka_admin_client~ KafkaAdminClient

new KafkaAdminClient()

Vert.x Kafka Admin client implementation
Source:

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
Source:

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
Source:

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
Source:

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
Source:

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
Source:

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
Source: