public class ClusterResource
extends java.lang.Object
ClusterResource
class encapsulates metadata for a Kafka cluster.Constructor and Description |
---|
ClusterResource(java.lang.String clusterId)
Create
ClusterResource with a cluster id. |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
clusterId()
Return the cluster id.
|
java.lang.String |
toString() |
public ClusterResource(java.lang.String clusterId)
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.clusterId
- public java.lang.String clusterId()
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.public java.lang.String toString()
toString
in class java.lang.Object