public class TierTopicManagerConfig
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
int |
brokerId |
java.lang.String |
clusterId |
java.lang.Integer |
commitIntervalMs |
short |
configuredNumPartitions |
short |
configuredReplicationFactor |
java.util.function.Supplier<java.util.Map<java.lang.String,java.lang.Object>> |
interBrokerClientConfigs |
java.util.List<java.lang.String> |
logDirs |
java.time.Duration |
pollDuration |
java.lang.Integer |
requestTimeoutMs |
java.lang.String |
tierNamespace |
Constructor and Description |
---|
TierTopicManagerConfig(kafka.server.KafkaConfig config,
java.util.function.Supplier<java.util.Map<java.lang.String,java.lang.Object>> interBrokerClientConfigs,
java.lang.String clusterId) |
TierTopicManagerConfig(java.util.function.Supplier<java.util.Map<java.lang.String,java.lang.Object>> interBrokerClientConfigs,
java.lang.String tierNamespace,
short configuredNumPartitions,
short configuredReplicationFactor,
int brokerId,
java.lang.String clusterId,
java.lang.Long pollDurationMs,
java.lang.Integer requestTimeoutMs,
java.lang.Integer commitIntervalMs,
java.util.List<java.lang.String> logDirs) |
public final java.util.function.Supplier<java.util.Map<java.lang.String,java.lang.Object>> interBrokerClientConfigs
public final java.lang.String tierNamespace
public final short configuredNumPartitions
public final short configuredReplicationFactor
public final int brokerId
public final java.lang.String clusterId
public final java.time.Duration pollDuration
public final java.lang.Integer commitIntervalMs
public final java.lang.Integer requestTimeoutMs
public final java.util.List<java.lang.String> logDirs
public TierTopicManagerConfig(java.util.function.Supplier<java.util.Map<java.lang.String,java.lang.Object>> interBrokerClientConfigs, java.lang.String tierNamespace, short configuredNumPartitions, short configuredReplicationFactor, int brokerId, java.lang.String clusterId, java.lang.Long pollDurationMs, java.lang.Integer requestTimeoutMs, java.lang.Integer commitIntervalMs, java.util.List<java.lang.String> logDirs)
public TierTopicManagerConfig(kafka.server.KafkaConfig config, java.util.function.Supplier<java.util.Map<java.lang.String,java.lang.Object>> interBrokerClientConfigs, java.lang.String clusterId)