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,
org.apache.kafka.common.Uuid topicId,
Set<org.apache.kafka.common.acl.AclOperation> authorizedOperations)
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
|
Copyright © 2024 Eclipse. All rights reserved.