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(org.apache.kafka.server.common.MetadataVersion interBrokerProtocolVersion) |
LogManagerBuilder |
setKeepPartitionMetadataFile(boolean keepPartitionMetadataFile) |
LogManagerBuilder |
setLogDirFailureChannel(kafka.server.LogDirFailureChannel logDirFailureChannel) |
LogManagerBuilder |
setLogDirs(List<File> logDirs) |
LogManagerBuilder |
setMaxProducerIdExpirationMs(int maxProducerIdExpirationMs) |
LogManagerBuilder |
setMaxTransactionTimeoutMs(int maxTransactionTimeoutMs) |
LogManagerBuilder |
setMetrics(org.apache.kafka.common.metrics.Metrics metrics) |
LogManagerBuilder |
setProducerIdQuotaManager(kafka.server.ProducerIdQuotaManager producerIdQuotaManager) |
LogManagerBuilder |
setRecoveryThreadsPerDataDir(int recoveryThreadsPerDataDir) |
LogManagerBuilder |
setRetentionCheckMs(long retentionCheckMs) |
LogManagerBuilder |
setScheduler(kafka.utils.Scheduler scheduler) |
LogManagerBuilder |
setSegmentDeletionThrottlerConfig(kafka.log.SegmentDeletionThrottlerConfig segmentDeletionThrottlerConfig) |
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 setSegmentDeletionThrottlerConfig(kafka.log.SegmentDeletionThrottlerConfig segmentDeletionThrottlerConfig)
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 setMaxTransactionTimeoutMs(int maxTransactionTimeoutMs)
public LogManagerBuilder setMaxProducerIdExpirationMs(int maxProducerIdExpirationMs)
public LogManagerBuilder setProducerIdQuotaManager(kafka.server.ProducerIdQuotaManager producerIdQuotaManager)
public LogManagerBuilder setInterBrokerProtocolVersion(org.apache.kafka.server.common.MetadataVersion 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()