public class MetadataClient extends Object
Modifier and Type | Class and Description |
---|---|
static class |
MetadataClient.Builder |
static class |
MetadataClient.ClusterAndGeneration |
static class |
MetadataClient.ClusterMetadata |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.Cluster |
cluster()
Get the current cluster.
|
MetadataClient.ClusterAndGeneration |
clusterAndGeneration()
Get the current cluster and generation
|
MetadataClient.ClusterAndGeneration |
forceRefreshMetadata()
Force-refresh metadata, paying no attention to how recently it has been refreshed.
|
MetadataClient.ClusterAndGeneration |
forceRefreshMetadata(int timeoutMs)
Force-refresh metadata, paying no attention to how recently it has been refreshed,
and bound the wait time for the call.
|
MetadataClient.ClusterAndGeneration |
maybeRefreshMetadata()
Refresh the metadata.
|
MetadataClient.ClusterAndGeneration |
maybeRefreshMetadata(int timeoutMs)
Refresh the metadata, but bound the wait time for the call.
|
public MetadataClient.ClusterAndGeneration maybeRefreshMetadata()
public MetadataClient.ClusterAndGeneration forceRefreshMetadata(int timeoutMs)
timeoutMs
- bound for the wait timepublic MetadataClient.ClusterAndGeneration forceRefreshMetadata()
public MetadataClient.ClusterAndGeneration maybeRefreshMetadata(int timeoutMs)
timeoutMs
- bound for the wait timepublic MetadataClient.ClusterAndGeneration clusterAndGeneration()
public org.apache.kafka.common.Cluster cluster()