public class TierTopicManagerConfig
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
java.lang.String |
bootstrapServers |
int |
brokerId |
java.lang.String |
clusterId |
java.lang.Integer |
commitIntervalMs |
java.util.List<java.lang.String> |
logDirs |
short |
numPartitions |
java.time.Duration |
pollDuration |
short |
replicationFactor |
java.lang.Integer |
requestTimeoutMs |
java.lang.String |
tierNamespace |
Constructor and Description |
---|
TierTopicManagerConfig(kafka.server.KafkaConfig config,
java.lang.String clusterId) |
TierTopicManagerConfig(java.lang.String bootstrapServers,
java.lang.String tierNamespace,
short numPartitions,
short replicationFactor,
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.lang.String bootstrapServers
public final java.lang.String tierNamespace
public final short numPartitions
public final short replicationFactor
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.lang.String bootstrapServers, java.lang.String tierNamespace, short numPartitions, short replicationFactor, 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.lang.String clusterId)