Class ClusterResource

java.lang.Object
org.apache.kafka.common.ClusterResource

public class ClusterResource
extends Object
The ClusterResource class encapsulates metadata for a Kafka cluster.
  • Constructor Details

    • ClusterResource

      public ClusterResource​(String clusterId)
      Create ClusterResource with a cluster id. Note that cluster id may be null if the metadata request was sent to a broker without support for cluster ids. The first version of Kafka to support cluster id is 0.10.1.0.
      Parameters:
      clusterId -
  • Method Details

    • clusterId

      public String clusterId()
      Return the cluster id. Note that it may be null if the metadata request was sent to a broker without support for cluster ids. The first version of Kafka to support cluster id is 0.10.1.0.
    • 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