public static class MetadataClient.Builder extends Object
Modifier and Type | Field and Description |
---|---|
KafkaCruiseControlConfig |
config |
int |
metadataTimeoutMs |
long |
metadataTtlMs |
boolean |
requiresTopicPlacement |
Constructor and Description |
---|
Builder(KafkaCruiseControlConfig config,
org.apache.kafka.common.utils.Time time,
UpdatableSbcGoalsConfig updatableSbcGoalsConfig) |
Modifier and Type | Method and Description |
---|---|
MetadataClient |
build(io.confluent.kafka.clients.CloudAdmin admin) |
public final int metadataTimeoutMs
public final long metadataTtlMs
public final boolean requiresTopicPlacement
public final KafkaCruiseControlConfig config
public Builder(KafkaCruiseControlConfig config, org.apache.kafka.common.utils.Time time, UpdatableSbcGoalsConfig updatableSbcGoalsConfig)
public MetadataClient build(io.confluent.kafka.clients.CloudAdmin admin)