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