public class KafkaAdminClient extends Object
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static TypeArg<KafkaAdminClient> |
__TYPE_ARG |
Constructor and Description |
---|
KafkaAdminClient(io.vertx.kafka.admin.KafkaAdminClient delegate) |
KafkaAdminClient(Object delegate) |
Modifier and Type | Method and Description |
---|---|
io.reactivex.rxjava3.core.Completable |
close()
Close the admin client
|
io.reactivex.rxjava3.core.Completable |
close(long timeout)
Close the admin client
|
static KafkaAdminClient |
create(Vertx vertx,
Map<String,String> config)
Create a new KafkaAdminClient instance
|
io.reactivex.rxjava3.core.Completable |
createPartitions(Map<String,io.vertx.kafka.admin.NewPartitions> partitions)
Creates a batch of new partitions in the Kafka topic
|
io.reactivex.rxjava3.core.Completable |
createTopics(List<io.vertx.kafka.admin.NewTopic> topics)
Creates a batch of new Kafka topics
|
io.reactivex.rxjava3.core.Completable |
deleteConsumerGroupOffsets(String groupId,
Set<io.vertx.kafka.client.common.TopicPartition> partitions)
Delete committed offsets for a set of partitions in a consumer group.
|
io.reactivex.rxjava3.core.Completable |
deleteConsumerGroups(List<String> groupIds)
Delete consumer groups from the cluster.
|
io.reactivex.rxjava3.core.Completable |
deleteTopics(List<String> topicNames)
Deletes a batch of Kafka topics
|
io.reactivex.rxjava3.core.Single<io.vertx.kafka.admin.ClusterDescription> |
describeCluster()
Describe the nodes in the cluster with the default options
|
io.reactivex.rxjava3.core.Single<Map<String,io.vertx.kafka.admin.ConsumerGroupDescription>> |
describeConsumerGroups(List<String> groupIds)
Describe some group ids in the cluster, with the default options
|
io.reactivex.rxjava3.core.Single<Map<String,io.vertx.kafka.admin.TopicDescription>> |
describeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.
|
boolean |
equals(Object o) |
io.vertx.kafka.admin.KafkaAdminClient |
getDelegate() |
int |
hashCode() |
io.reactivex.rxjava3.core.Single<List<io.vertx.kafka.admin.ConsumerGroupListing>> |
listConsumerGroups()
Get the the consumer groups available in the cluster with the default options
|
io.reactivex.rxjava3.core.Single<Set<String>> |
listTopics()
List the topics available in the cluster with the default options.
|
static KafkaAdminClient |
newInstance(io.vertx.kafka.admin.KafkaAdminClient arg) |
io.reactivex.rxjava3.core.Completable |
rxClose()
Close the admin client
|
io.reactivex.rxjava3.core.Completable |
rxClose(long timeout)
Close the admin client
|
io.reactivex.rxjava3.core.Completable |
rxCreatePartitions(Map<String,io.vertx.kafka.admin.NewPartitions> partitions)
Creates a batch of new partitions in the Kafka topic
|
io.reactivex.rxjava3.core.Completable |
rxCreateTopics(List<io.vertx.kafka.admin.NewTopic> topics)
Creates a batch of new Kafka topics
|
io.reactivex.rxjava3.core.Completable |
rxDeleteConsumerGroupOffsets(String groupId,
Set<io.vertx.kafka.client.common.TopicPartition> partitions)
Delete committed offsets for a set of partitions in a consumer group.
|
io.reactivex.rxjava3.core.Completable |
rxDeleteConsumerGroups(List<String> groupIds)
Delete consumer groups from the cluster.
|
io.reactivex.rxjava3.core.Completable |
rxDeleteTopics(List<String> topicNames)
Deletes a batch of Kafka topics
|
io.reactivex.rxjava3.core.Single<io.vertx.kafka.admin.ClusterDescription> |
rxDescribeCluster()
Describe the nodes in the cluster with the default options
|
io.reactivex.rxjava3.core.Single<Map<String,io.vertx.kafka.admin.ConsumerGroupDescription>> |
rxDescribeConsumerGroups(List<String> groupIds)
Describe some group ids in the cluster, with the default options
|
io.reactivex.rxjava3.core.Single<Map<String,io.vertx.kafka.admin.TopicDescription>> |
rxDescribeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.
|
io.reactivex.rxjava3.core.Single<List<io.vertx.kafka.admin.ConsumerGroupListing>> |
rxListConsumerGroups()
Get the the consumer groups available in the cluster with the default options
|
io.reactivex.rxjava3.core.Single<Set<String>> |
rxListTopics()
List the topics available in the cluster with the default options.
|
String |
toString() |
public static final TypeArg<KafkaAdminClient> __TYPE_ARG
public KafkaAdminClient(io.vertx.kafka.admin.KafkaAdminClient delegate)
public KafkaAdminClient(Object delegate)
public io.vertx.kafka.admin.KafkaAdminClient getDelegate()
public static KafkaAdminClient create(Vertx vertx, Map<String,String> config)
vertx
- Vert.x instance to useconfig
- Kafka admin client configurationpublic io.reactivex.rxjava3.core.Single<Set<String>> listTopics()
public io.reactivex.rxjava3.core.Single<Set<String>> rxListTopics()
public io.reactivex.rxjava3.core.Single<Map<String,io.vertx.kafka.admin.TopicDescription>> describeTopics(List<String> topicNames)
topicNames
- the names of the topics to describepublic io.reactivex.rxjava3.core.Single<Map<String,io.vertx.kafka.admin.TopicDescription>> rxDescribeTopics(List<String> topicNames)
topicNames
- the names of the topics to describepublic io.reactivex.rxjava3.core.Completable createTopics(List<io.vertx.kafka.admin.NewTopic> topics)
topics
- topics to createpublic io.reactivex.rxjava3.core.Completable rxCreateTopics(List<io.vertx.kafka.admin.NewTopic> topics)
topics
- topics to createpublic io.reactivex.rxjava3.core.Completable deleteTopics(List<String> topicNames)
topicNames
- the names of the topics to deletepublic io.reactivex.rxjava3.core.Completable rxDeleteTopics(List<String> topicNames)
topicNames
- the names of the topics to deletepublic io.reactivex.rxjava3.core.Completable createPartitions(Map<String,io.vertx.kafka.admin.NewPartitions> partitions)
partitions
- partitions to createpublic io.reactivex.rxjava3.core.Completable rxCreatePartitions(Map<String,io.vertx.kafka.admin.NewPartitions> partitions)
partitions
- partitions to createpublic io.reactivex.rxjava3.core.Single<List<io.vertx.kafka.admin.ConsumerGroupListing>> listConsumerGroups()
public io.reactivex.rxjava3.core.Single<List<io.vertx.kafka.admin.ConsumerGroupListing>> rxListConsumerGroups()
public io.reactivex.rxjava3.core.Single<Map<String,io.vertx.kafka.admin.ConsumerGroupDescription>> describeConsumerGroups(List<String> groupIds)
groupIds
- the ids of the groups to describepublic io.reactivex.rxjava3.core.Single<Map<String,io.vertx.kafka.admin.ConsumerGroupDescription>> rxDescribeConsumerGroups(List<String> groupIds)
groupIds
- the ids of the groups to describepublic io.reactivex.rxjava3.core.Single<io.vertx.kafka.admin.ClusterDescription> describeCluster()
public io.reactivex.rxjava3.core.Single<io.vertx.kafka.admin.ClusterDescription> rxDescribeCluster()
public io.reactivex.rxjava3.core.Completable deleteConsumerGroups(List<String> groupIds)
groupIds
- the ids of the groups to deletepublic io.reactivex.rxjava3.core.Completable rxDeleteConsumerGroups(List<String> groupIds)
groupIds
- the ids of the groups to deletepublic io.reactivex.rxjava3.core.Completable deleteConsumerGroupOffsets(String groupId, Set<io.vertx.kafka.client.common.TopicPartition> partitions)
groupId
- The group id of the group whose offsets will be deletedpartitions
- The set of partitions in the consumer group whose offsets will be deletedpublic io.reactivex.rxjava3.core.Completable rxDeleteConsumerGroupOffsets(String groupId, Set<io.vertx.kafka.client.common.TopicPartition> partitions)
groupId
- The group id of the group whose offsets will be deletedpartitions
- The set of partitions in the consumer group whose offsets will be deletedpublic io.reactivex.rxjava3.core.Completable close()
public io.reactivex.rxjava3.core.Completable rxClose()
public io.reactivex.rxjava3.core.Completable close(long timeout)
timeout
- timeout to wait for closingpublic io.reactivex.rxjava3.core.Completable rxClose(long timeout)
timeout
- timeout to wait for closingpublic static KafkaAdminClient newInstance(io.vertx.kafka.admin.KafkaAdminClient arg)
Copyright © 2021 Eclipse. All rights reserved.