public class TierTopicManagerConfig extends Object
Modifier and Type | Field and Description |
---|---|
int |
brokerId |
String |
clusterId |
Integer |
commitIntervalMs |
short |
configuredNumPartitions |
short |
configuredReplicationFactor |
Boolean |
enableProducerIdempotence |
Boolean |
enableSnapshotBasedMaterialization |
Boolean |
enableTierTopicDataLossDetection |
Boolean |
enableTierTopicFencingDuringDataLoss |
Supplier<Map<String,Object>> |
interBrokerClientConfigs |
List<String> |
logDirs |
static long |
MATERIALIZATION_DELTA_MS |
Long |
materializationTimeRangeMs |
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,
Long materializationTimeRangeMs,
List<String> logDirs,
Boolean enableProducerIdempotence,
Boolean enableTierTopicDataLossDetection,
Boolean enableTierTopicFencingDuringDataLoss,
Boolean enableSnapshotBasedMaterialization) |
Modifier and Type | Method and Description |
---|---|
static TierTopicManagerConfig |
reconfigureTierTopicManagerConfig(TierTopicManagerConfig oldConfig,
kafka.server.KafkaConfig newConfig) |
public static final long MATERIALIZATION_DELTA_MS
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 requestTimeoutMs
public final Integer commitIntervalMs
public final Long materializationTimeRangeMs
public final Boolean enableProducerIdempotence
public final Boolean enableTierTopicDataLossDetection
public final Boolean enableTierTopicFencingDuringDataLoss
public final Boolean enableSnapshotBasedMaterialization
public TierTopicManagerConfig(Supplier<Map<String,Object>> interBrokerClientConfigs, String tierNamespace, short configuredNumPartitions, short configuredReplicationFactor, int brokerId, String clusterId, Long pollDurationMs, Integer requestTimeoutMs, Integer commitIntervalMs, Long materializationTimeRangeMs, List<String> logDirs, Boolean enableProducerIdempotence, Boolean enableTierTopicDataLossDetection, Boolean enableTierTopicFencingDuringDataLoss, Boolean enableSnapshotBasedMaterialization)
public static TierTopicManagerConfig reconfigureTierTopicManagerConfig(TierTopicManagerConfig oldConfig, kafka.server.KafkaConfig newConfig)