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 id

  leader - the leader of the partition or Node.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

• ofReplicasAndObservers

  @Confluent
  public static TopicPartitionInfo ofReplicasAndObservers(int partition,
                                                                     Node leader,
                                                                     List<Node> replicas,
                                                                     List<Node> observers,
                                                                     List<Node> isr)

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

• observers

  @Confluent
  public List<Node> observers()

  Return the observer replicas of the partition. Observers are not part of ISR and cannot be elected as leader.

• isr

  public List<Node> isr()

  Return the in-sync replicas of the partition. Note that the ordering of the result is unspecified.

• toString

  public String toString()

  Overrides:

  toString in class Object

• equals

  public boolean equals(Object o)

  Overrides:

  equals in class Object

• hashCode

  public int hashCode()

  Overrides:

  hashCode in class Object