Skip to content

Commit 3d353eb

Browse files
authored
MINOR: Remove unused fields in KafkaConfig (#19481)
This is a follow-up clean of #19387 Since we no longer access the log cleaner config from `KafkaConfig`, we should remove these unused fields. Reviewers: Ken Huang <[email protected]>, Chia-Ping Tsai <[email protected]>
1 parent 6e26ec0 commit 3d353eb

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

Diff for: core/src/main/scala/kafka/server/KafkaConfig.scala

-4
Original file line numberDiff line numberDiff line change
@@ -333,13 +333,9 @@ class KafkaConfig private(doLog: Boolean, val props: util.Map[_, _])
333333

334334
def logRetentionBytes = getLong(ServerLogConfigs.LOG_RETENTION_BYTES_CONFIG)
335335
def logCleanerDedupeBufferSize = getLong(CleanerConfig.LOG_CLEANER_DEDUPE_BUFFER_SIZE_PROP)
336-
def logCleanerDedupeBufferLoadFactor = getDouble(CleanerConfig.LOG_CLEANER_DEDUPE_BUFFER_LOAD_FACTOR_PROP)
337-
def logCleanerIoBufferSize = getInt(CleanerConfig.LOG_CLEANER_IO_BUFFER_SIZE_PROP)
338-
def logCleanerIoMaxBytesPerSecond = getDouble(CleanerConfig.LOG_CLEANER_IO_MAX_BYTES_PER_SECOND_PROP)
339336
def logCleanerDeleteRetentionMs = getLong(CleanerConfig.LOG_CLEANER_DELETE_RETENTION_MS_PROP)
340337
def logCleanerMinCompactionLagMs = getLong(CleanerConfig.LOG_CLEANER_MIN_COMPACTION_LAG_MS_PROP)
341338
def logCleanerMaxCompactionLagMs = getLong(CleanerConfig.LOG_CLEANER_MAX_COMPACTION_LAG_MS_PROP)
342-
def logCleanerBackoffMs = getLong(CleanerConfig.LOG_CLEANER_BACKOFF_MS_PROP)
343339
def logCleanerMinCleanRatio = getDouble(CleanerConfig.LOG_CLEANER_MIN_CLEAN_RATIO_PROP)
344340
def logIndexSizeMaxBytes = getInt(ServerLogConfigs.LOG_INDEX_SIZE_MAX_BYTES_CONFIG)
345341
def logIndexIntervalBytes = getInt(ServerLogConfigs.LOG_INDEX_INTERVAL_BYTES_CONFIG)

0 commit comments

Comments
 (0)