io.vertx.reactivex.kafka.admin

Class KafkaAdminClient

java.lang.Object

io.vertx.reactivex.kafka.admin.KafkaAdminClient

public class KafkaAdminClient
extends Object

Vert.x Kafka Admin client implementation

NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

Field Summary

Fields

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<KafkaAdminClient>	__TYPE_ARG

Constructor Summary

Constructors

Constructor and Description
KafkaAdminClient(KafkaAdminClient delegate)
KafkaAdminClient(Object delegate)

Method Summary

Modifier and Type	Method and Description
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, Map<String,String> config) Create a new KafkaAdminClient instance
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
boolean	equals(Object o)
KafkaAdminClient	getDelegate()
int	hashCode()
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.
static KafkaAdminClient	newInstance(KafkaAdminClient arg)
Completable	rxClose() Close the admin client
Completable	rxClose(long timeout) Close the admin client
Completable	rxCreateTopics(List<NewTopic> topics) Creates a batch of new Kafka topics
Completable	rxDeleteTopics(List<String> topicNames) Deletes a batch of Kafka topics
Single<List<ConsumerGroupListing>>	rxListConsumerGroups() Get the the consumer groups available in the cluster with the default options
Single<Set<String>>	rxListTopics() List the topics available in the cluster with the default options.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

__TYPE_ARG

public static final io.vertx.lang.rx.TypeArg<KafkaAdminClient> __TYPE_ARG

Constructor Detail

KafkaAdminClient

public KafkaAdminClient(KafkaAdminClient delegate)

KafkaAdminClient

public KafkaAdminClient(Object delegate)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

getDelegate

public KafkaAdminClient getDelegate()

create

public static KafkaAdminClient create(Vertx vertx,
                                      Map<String,String> config)

Create a new KafkaAdminClient instance

Parameters:

vertx - Vert.x instance to use

config - Kafka admin client configuration

Returns:

an instance of the KafkaAdminClient

listTopics

public void listTopics(Handler<AsyncResult<Set<String>>> completionHandler)

List the topics available in the cluster with the default options.

Parameters:

completionHandler - handler called on operation completed with the topics set

rxListTopics

public Single<Set<String>> rxListTopics()

List the topics available in the cluster with the default options.

Returns:

createTopics

public void createTopics(List<NewTopic> topics,
                         Handler<AsyncResult<Void>> completionHandler)

Creates a batch of new Kafka topics

Parameters:

topics - topics to create

completionHandler - handler called on operation completed

rxCreateTopics

public Completable rxCreateTopics(List<NewTopic> topics)

Creates a batch of new Kafka topics

Parameters:

topics - topics to create

Returns:

deleteTopics

public void deleteTopics(List<String> topicNames,
                         Handler<AsyncResult<Void>> completionHandler)

Deletes a batch of Kafka topics

Parameters:

topicNames - the names of the topics to delete

completionHandler - handler called on operation completed

rxDeleteTopics

public Completable rxDeleteTopics(List<String> topicNames)

Deletes a batch of Kafka topics

Parameters:

topicNames - the names of the topics to delete

Returns:

listConsumerGroups

public void listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)

Get the the consumer groups available in the cluster with the default options

Parameters:

completionHandler - handler called on operation completed with the consumer groups ids

rxListConsumerGroups

public Single<List<ConsumerGroupListing>> rxListConsumerGroups()

Get the the consumer groups available in the cluster with the default options

Returns:

close

public void close()

Close the admin client

close

public void close(Handler<AsyncResult<Void>> completionHandler)

Close the admin client

Parameters:

completionHandler - handler called on operation completed

rxClose

public Completable rxClose()

Close the admin client

Returns:

close

public void close(long timeout,
                  Handler<AsyncResult<Void>> completionHandler)

Close the admin client

Parameters:

timeout - timeout to wait for closing

completionHandler - handler called on operation completed

rxClose

public Completable rxClose(long timeout)

Close the admin client

Parameters:

timeout - timeout to wait for closing

Returns:

newInstance

public static KafkaAdminClient newInstance(KafkaAdminClient arg)