Package 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	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	Description
boolean	equals(Object obj)
int	hashCode()
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

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

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 Details

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

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object