Package org.apache.kafka.common
Class ClusterResource
- java.lang.Object
-
- org.apache.kafka.common.ClusterResource
-
public class ClusterResource extends Object
TheClusterResource
class encapsulates metadata for a Kafka cluster.
-
-
Constructor Summary
Constructors Constructor Description ClusterResource(String clusterId)
CreateClusterResource
with a cluster id.
-
-
-
Constructor Detail
-
ClusterResource
public ClusterResource(String clusterId)
CreateClusterResource
with a cluster id. Note that cluster id may benull
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 Detail
-
clusterId
public String clusterId()
Return the cluster id. Note that it may benull
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.
-
-