org.apache.kafka.common

Class PartitionInfo

java.lang.Object

org.apache.kafka.common.PartitionInfo

public class PartitionInfo
extends Object

This is used to describe per-partition state in the MetadataResponse.

Constructor Summary

Constructors

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)

Method Summary

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

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

PartitionInfo

public PartitionInfo(String topic,
                     int partition,
                     Node leader,
                     Node[] replicas,
                     Node[] inSyncReplicas)

PartitionInfo

public PartitionInfo(String topic,
                     int partition,
                     Node leader,
                     Node[] replicas,
                     Node[] inSyncReplicas,
                     Node[] offlineReplicas)

Method Detail

of

@Confluent
public static PartitionInfo of(String topic,
                                          int partition,
                                          Node leader,
                                          Node[] replicas,
                                          Node[] observers,
                                          Node[] inSyncReplicas,
                                          Node[] offlineReplicas)

topic

public String topic()

The topic name

partition

public int partition()

The partition id

leader

public Node leader()

The node id of the node currently acting as a leader for this partition or null if there is no leader

replicas

public Node[] replicas()

The complete set of replicas for this partition regardless of whether they are alive or up-to-date

observers

public Node[] observers()

The complete set of observers for this partition regardless of whether they are alive or up-to-date

inSyncReplicas

public 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

offlineReplicas

public Node[] offlineReplicas()

The subset of the replicas that are offline

toString

public String toString()

Overrides:

toString in class Object