public class LogManagerBuilder extends Object
Constructor and Description |
---|
LogManagerBuilder() |
Modifier and Type | Method and Description |
---|---|
kafka.log.LogManager |
build() |
LogManagerBuilder |
setBrokerTopicStats(kafka.server.BrokerTopicStats brokerTopicStats) |
LogManagerBuilder |
setCleanerConfig(kafka.log.CleanerConfig cleanerConfig) |
LogManagerBuilder |
setConfigRepository(kafka.server.metadata.ConfigRepository configRepository) |
LogManagerBuilder |
setFlushCheckMs(long flushCheckMs) |
LogManagerBuilder |
setFlushRecoveryOffsetCheckpointMs(long flushRecoveryOffsetCheckpointMs) |
LogManagerBuilder |
setFlushStartOffsetCheckpointMs(long flushStartOffsetCheckpointMs) |
LogManagerBuilder |
setInitialDefaultConfig(kafka.log.LogConfig initialDefaultConfig) |
LogManagerBuilder |
setInitialOfflineDirs(List<File> initialOfflineDirs) |
LogManagerBuilder |
setInterBrokerProtocolVersion(kafka.api.ApiVersion interBrokerProtocolVersion) |
LogManagerBuilder |
setKeepPartitionMetadataFile(boolean keepPartitionMetadataFile) |
LogManagerBuilder |
setLogDeletionMaxSegmentsPerRun(int logDeletionMaxSegmentsPerRun) |
LogManagerBuilder |
setLogDirFailureChannel(kafka.server.LogDirFailureChannel logDirFailureChannel) |
LogManagerBuilder |
setLogDirs(List<File> logDirs) |
LogManagerBuilder |
setMaxPidExpirationMs(int maxPidExpirationMs) |
LogManagerBuilder |
setMaxTransactionTimeoutMs(int maxTransactionTimeoutMs) |
LogManagerBuilder |
setMetrics(org.apache.kafka.common.metrics.Metrics metrics) |
LogManagerBuilder |
setRecoveryThreadsPerDataDir(int recoveryThreadsPerDataDir) |
LogManagerBuilder |
setRetentionCheckMs(long retentionCheckMs) |
LogManagerBuilder |
setScheduler(kafka.utils.Scheduler scheduler) |
LogManagerBuilder |
setTierLogComponents(kafka.log.TierLogComponents tierLogComponents) |
LogManagerBuilder |
setTierStateCheckpointMs(int tierStateCheckpointMs) |
LogManagerBuilder |
setTime(org.apache.kafka.common.utils.Time time) |
public LogManagerBuilder setLogDirs(List<File> logDirs)
public LogManagerBuilder setInitialOfflineDirs(List<File> initialOfflineDirs)
public LogManagerBuilder setConfigRepository(kafka.server.metadata.ConfigRepository configRepository)
public LogManagerBuilder setInitialDefaultConfig(kafka.log.LogConfig initialDefaultConfig)
public LogManagerBuilder setCleanerConfig(kafka.log.CleanerConfig cleanerConfig)
public LogManagerBuilder setRecoveryThreadsPerDataDir(int recoveryThreadsPerDataDir)
public LogManagerBuilder setFlushCheckMs(long flushCheckMs)
public LogManagerBuilder setFlushRecoveryOffsetCheckpointMs(long flushRecoveryOffsetCheckpointMs)
public LogManagerBuilder setFlushStartOffsetCheckpointMs(long flushStartOffsetCheckpointMs)
public LogManagerBuilder setTierStateCheckpointMs(int tierStateCheckpointMs)
public LogManagerBuilder setRetentionCheckMs(long retentionCheckMs)
public LogManagerBuilder setLogDeletionMaxSegmentsPerRun(int logDeletionMaxSegmentsPerRun)
public LogManagerBuilder setMaxTransactionTimeoutMs(int maxTransactionTimeoutMs)
public LogManagerBuilder setMaxPidExpirationMs(int maxPidExpirationMs)
public LogManagerBuilder setInterBrokerProtocolVersion(kafka.api.ApiVersion interBrokerProtocolVersion)
public LogManagerBuilder setScheduler(kafka.utils.Scheduler scheduler)
public LogManagerBuilder setBrokerTopicStats(kafka.server.BrokerTopicStats brokerTopicStats)
public LogManagerBuilder setLogDirFailureChannel(kafka.server.LogDirFailureChannel logDirFailureChannel)
public LogManagerBuilder setTierLogComponents(kafka.log.TierLogComponents tierLogComponents)
public LogManagerBuilder setMetrics(org.apache.kafka.common.metrics.Metrics metrics)
public LogManagerBuilder setTime(org.apache.kafka.common.utils.Time time)
public LogManagerBuilder setKeepPartitionMetadataFile(boolean keepPartitionMetadataFile)
public kafka.log.LogManager build()