Package org.apache.kafka.common
Class TopicPartitionInfo
- java.lang.Object
-
- org.apache.kafka.common.TopicPartitionInfo
-
public class TopicPartitionInfo extends Object
A class containing leadership, replicas and ISR information for a topic partition.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
int
hashCode()
List<Node>
isr()
Return the in-sync replicas of the partition.Node
leader()
Return the leader of the partition or null if there is none.int
partition()
Return the partition id.List<Node>
replicas()
Return the replicas of the partition in the same order as the replica assignment.String
toString()
-
-
-
Constructor Detail
-
TopicPartitionInfo
public TopicPartitionInfo(int partition, Node leader, List<Node> replicas, List<Node> isr)
Create an instance of this class with the provided parameters.- Parameters:
partition
- the partition idleader
- the leader of the partition orNode.noNode()
if there is none.replicas
- the replicas of the partition in the same order as the replica assignment (the preferred replica is the head of the list)isr
- the in-sync replicas
-
-
Method Detail
-
partition
public int partition()
Return the partition id.
-
leader
public Node leader()
Return the leader of the partition or null if there is none.
-
replicas
public List<Node> replicas()
Return the replicas of the partition in the same order as the replica assignment. The preferred replica is the head of the list. Brokers with version lower than 0.11.0.0 return the replicas in unspecified order due to a bug.
-
isr
public List<Node> isr()
Return the in-sync replicas of the partition. Note that the ordering of the result is unspecified.
-
-