org.apache.kafka.common

Class PartitionInfo

java.lang.Object

org.apache.kafka.common.PartitionInfo

public class PartitionInfo
extends Object

Information about a topic-partition.

Constructor Summary

Constructors

Constructor and Description
PartitionInfo(String topic, int partition, Node leader, Node[] replicas, Node[] inSyncReplicas)

Method Summary

Methods

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

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

PartitionInfo

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

Method Detail

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

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

toString

public String toString()

Overrides:

toString in class Object