public static class MetadataClient.Builder extends Object
Modifier and Type | Field and Description |
---|---|
ConfigSupplier |
configSupplier |
int |
metadataTimeoutMs |
long |
metadataTtlMs |
boolean |
requiresTopicPlacement |
Constructor and Description |
---|
Builder(ConfigSupplier configSupplier,
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 ConfigSupplier configSupplier
public Builder(ConfigSupplier configSupplier, org.apache.kafka.common.utils.Time time, UpdatableSbcGoalsConfig updatableSbcGoalsConfig)
public MetadataClient build(io.confluent.kafka.clients.CloudAdmin admin)