Package | Description |
---|---|
io.vertx.kafka.admin | |
io.vertx.reactivex.kafka.admin | |
io.vertx.rxjava.kafka.admin | |
io.vertx.rxjava3.kafka.admin |
Modifier and Type | Method and Description |
---|---|
TopicDescription |
TopicDescription.setAuthorizedOperations(Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)
Set the id of the consumer group
|
TopicDescription |
TopicDescription.setInternal(boolean internal)
Set whether the topic is internal to Kafka.
|
TopicDescription |
TopicDescription.setName(String name)
Set the name of the topic.
|
TopicDescription |
TopicDescription.setPartitions(List<TopicPartitionInfo> partitions)
Set A list of partitions where the index represents the partition id and the element
contains leadership and replica information for that partition.
|
TopicDescription |
TopicDescription.setTopicId(org.apache.kafka.common.Uuid topicId)
Set the id of the topic.
|
Modifier and Type | Method and Description |
---|---|
Future<Map<String,TopicDescription>> |
KafkaAdminClient.describeTopics(List<String> topicNames)
Like
KafkaAdminClient.describeTopics(List, Handler) but returns a Future of the asynchronous result |
Future<Map<String,TopicDescription>> |
KafkaAdminClient.describeTopics(List<String> topicNames,
DescribeTopicsOptions options)
Like
KafkaAdminClient.describeTopics(List, DescribeTopicsOptions, Handler) but returns a Future of the asynchronous result |
Modifier and Type | Method and Description |
---|---|
static void |
TopicDescriptionConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
TopicDescription obj) |
static void |
TopicDescriptionConverter.toJson(TopicDescription obj,
JsonObject json) |
static void |
TopicDescriptionConverter.toJson(TopicDescription obj,
Map<String,Object> json) |
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.describeTopics(List<String> topicNames,
DescribeTopicsOptions options,
Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
Like
KafkaAdminClient.describeTopics(List, Handler) but allows for customised otions |
void |
KafkaAdminClient.describeTopics(List<String> topicNames,
Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
Describe some topics in the cluster, with the default options.
|
Modifier and Type | Method and Description |
---|---|
Single<Map<String,TopicDescription>> |
KafkaAdminClient.rxDescribeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.
|
Single<Map<String,TopicDescription>> |
KafkaAdminClient.rxDescribeTopics(List<String> topicNames,
DescribeTopicsOptions options)
|
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.describeTopics(List<String> topicNames,
DescribeTopicsOptions options,
Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
|
void |
KafkaAdminClient.describeTopics(List<String> topicNames,
Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
Describe some topics in the cluster, with the default options.
|
Modifier and Type | Method and Description |
---|---|
Single<Map<String,TopicDescription>> |
KafkaAdminClient.rxDescribeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.
|
Single<Map<String,TopicDescription>> |
KafkaAdminClient.rxDescribeTopics(List<String> topicNames,
DescribeTopicsOptions options)
|
Modifier and Type | Method and Description |
---|---|
void |
KafkaAdminClient.describeTopics(List<String> topicNames,
DescribeTopicsOptions options,
Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
|
void |
KafkaAdminClient.describeTopics(List<String> topicNames,
Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
Describe some topics in the cluster, with the default options.
|
Modifier and Type | Method and Description |
---|---|
Single<Map<String,TopicDescription>> |
KafkaAdminClient.describeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.
|
Single<Map<String,TopicDescription>> |
KafkaAdminClient.describeTopics(List<String> topicNames,
DescribeTopicsOptions options)
Like
KafkaAdminClient.describeTopics(java.util.List<java.lang.String>) but allows for customised otions |
Single<Map<String,TopicDescription>> |
KafkaAdminClient.rxDescribeTopics(List<String> topicNames)
Describe some topics in the cluster, with the default options.
|
Single<Map<String,TopicDescription>> |
KafkaAdminClient.rxDescribeTopics(List<String> topicNames,
DescribeTopicsOptions options)
Like
KafkaAdminClient.describeTopics(java.util.List<java.lang.String>) but allows for customised otions |
Copyright © 2023 Eclipse. All rights reserved.