Package | Description |
---|---|
io.vertx.kafka.client.common |
Modifier and Type | Method and Description |
---|---|
Node |
PartitionInfo.getLeader() |
Node |
Node.setHasRack(boolean hasRack)
Set if this node has a defined rack
|
Node |
Node.setHost(String host)
Set the host name for this node
|
Node |
Node.setId(int id)
Set the node id of this node
|
Node |
Node.setIdString(String idString)
Set the string representation of the node id
|
Node |
Node.setIsEmpty(boolean isEmpty)
Set if this node is empty
|
Node |
Node.setPort(int port)
Set the port for this node
|
Node |
Node.setRack(String rack)
Set the rack for this node
|
Modifier and Type | Method and Description |
---|---|
List<Node> |
PartitionInfo.getInSyncReplicas() |
List<Node> |
PartitionInfo.getReplicas() |
Modifier and Type | Method and Description |
---|---|
PartitionInfo |
PartitionInfo.setLeader(Node leader)
Set the node id of the node currently acting as a leader
|
Modifier and Type | Method and Description |
---|---|
PartitionInfo |
PartitionInfo.setInSyncReplicas(List<Node> inSyncReplicas)
Set the subset of the replicas that are in sync
|
PartitionInfo |
PartitionInfo.setReplicas(List<Node> replicas)
Set the complete set of replicas for this partition
|
Constructor and Description |
---|
PartitionInfo(List<Node> inSyncReplicas,
Node leader,
int partition,
List<Node> replicas,
String topic)
Constructor
|
Constructor and Description |
---|
PartitionInfo(List<Node> inSyncReplicas,
Node leader,
int partition,
List<Node> replicas,
String topic)
Constructor
|
PartitionInfo(List<Node> inSyncReplicas,
Node leader,
int partition,
List<Node> replicas,
String topic)
Constructor
|
Copyright © 2018 Eclipse. All rights reserved.