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()