add log cleaner properties to kafka configs (#34)

hypertrace · Dec 29, 2022 · 3a090ef · 3a090ef
1 parent e566c14
commit 3a090ef
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/helm/templates/configmap.yaml b/helm/templates/configmap.yaml
@@ -256,6 +256,15 @@ data:
     replication.quota.window.size.seconds={{ int .Values.config.replicationQuotaWindowSizeSeconds }}
     {{- end }}
 
+    {{- if .Values.config.logCleanerThreads }}
+    # The number of background threads to use for log cleaning
+    log.cleaner.threads={{ int .Values.config.logCleanerThreads }}
+    {{- end }}
+
+    {{- if .Values.config.logCleanerDeleteRetentionMs }}
+    # The amount of time to retain delete tombstone markers for log compacted topics.
+    log.cleaner.delete.retention.ms={{ int .Values.config.logCleanerDeleteRetentionMs }}
+    {{- end }}
   log4j.properties: |+
     # Licensed to the Apache Software Foundation (ASF) under one or more
     # contributor license agreements.  See the NOTICE file distributed with

diff --git a/helm/values.yaml b/helm/values.yaml
@@ -74,7 +74,9 @@ config:
   deleteTopicEnable: true
   groupInitialRebalanceDelayMs: 3000
   interBrokerListenerName: PLAINTEXT
-  interBrokerProtocolVersion: "2.6"
+  interBrokerProtocolVersion: "3.2"
+  logCleanerDeleteRetentionMs: ""
+  logCleanerThreads: ""
   logDirs: /var/lib/kafka/data/topics
   logFlushIntervalMessages: ""
   logFlushIntervalMs: ""