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

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