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.