Package org.apache.kafka.common
Class ClusterResource
- java.lang.Object
-
- org.apache.kafka.common.ClusterResource
-
public class ClusterResource extends Object
TheClusterResourceclass encapsulates metadata for a Kafka cluster.
-
-
Constructor Summary
Constructors Constructor Description ClusterResource(String clusterId)CreateClusterResourcewith a cluster id.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description StringclusterId()Return the cluster id.booleanequals(Object o)inthashCode()StringtoString()
-
-
-
Constructor Detail
-
ClusterResource
public ClusterResource(String clusterId)
CreateClusterResourcewith a cluster id. Note that cluster id may benullif 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 Detail
-
clusterId
public String clusterId()
Return the cluster id. Note that it may benullif 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.
-
-