public class PartitionInfo extends Object
Constructor and Description |
---|
PartitionInfo(String topic,
int partition,
Node leader,
Node[] replicas,
Node[] inSyncReplicas) |
PartitionInfo(String topic,
int partition,
Node leader,
Node[] replicas,
Node[] inSyncReplicas,
Node[] offlineReplicas) |
Modifier and Type | Method and Description |
---|---|
Node[] |
inSyncReplicas()
The subset of the replicas that are in sync, that is caught-up to the leader and ready to take over as leader if
the leader should fail
|
Node |
leader()
The node id of the node currently acting as a leader for this partition or null if there is no leader
|
Node[] |
observers()
The complete set of observers for this partition regardless of whether they are alive or up-to-date
|
static PartitionInfo |
of(String topic,
int partition,
Node leader,
Node[] replicas,
Node[] observers,
Node[] inSyncReplicas,
Node[] offlineReplicas) |
Node[] |
offlineReplicas()
The subset of the replicas that are offline
|
int |
partition()
The partition id
|
Node[] |
replicas()
The complete set of replicas for this partition regardless of whether they are alive or up-to-date
|
String |
topic()
The topic name
|
String |
toString() |
public PartitionInfo(String topic, int partition, Node leader, Node[] replicas, Node[] inSyncReplicas)
@Confluent public static PartitionInfo of(String topic, int partition, Node leader, Node[] replicas, Node[] observers, Node[] inSyncReplicas, Node[] offlineReplicas)
public String topic()
public int partition()
public Node leader()
public Node[] replicas()
public Node[] observers()
public Node[] inSyncReplicas()
public Node[] offlineReplicas()