Package | Description |
---|---|
io.vertx.kafka.admin | |
io.vertx.kafka.client.common |
Modifier and Type | Method and Description |
---|---|
List<TopicPartitionInfo> |
TopicDescription.getPartitions() |
Modifier and Type | Method and Description |
---|---|
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.
|
Constructor and Description |
---|
TopicDescription(boolean isInternal,
String name,
List<TopicPartitionInfo> partitions)
Constructor
|
Modifier and Type | Method and Description |
---|---|
TopicPartitionInfo |
TopicPartitionInfo.setIsr(List<Node> isr)
Set the subset of the replicas that are in sync
|
TopicPartitionInfo |
TopicPartitionInfo.setLeader(Node leader)
Set the node id of the node currently acting as a leader
|
TopicPartitionInfo |
TopicPartitionInfo.setPartition(int partition)
Set the partition id
|
TopicPartitionInfo |
TopicPartitionInfo.setReplicas(List<Node> replicas)
Set the complete set of replicas for this partition
|
Modifier and Type | Method and Description |
---|---|
static void |
TopicPartitionInfoConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
TopicPartitionInfo obj) |
static void |
TopicPartitionInfoConverter.toJson(TopicPartitionInfo obj,
JsonObject json) |
static void |
TopicPartitionInfoConverter.toJson(TopicPartitionInfo obj,
Map<String,Object> json) |
Copyright © 2021 Eclipse. All rights reserved.