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