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