fix: Improved handling of defaults for storage topics (#5)

charts/kafka-connect/Chart.yaml

@@ -15,7 +15,7 @@ type: application
 # This is the chart version. This version number should be incremented each time you make changes
 # to the chart and its templates, including the app version.
 # Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 0.1.3
+version: 0.1.4
 
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application. Versions are not expected to

charts/kafka-connect/templates/_helpers.tpl

@@ -69,8 +69,10 @@ Create the name of the config topic to use
 {{- $config := .config -}}
 {{- $clustername := .clustername -}}
 {{- $topic_prefix := (printf "%s-%s" $global.configTopicPrefix $clustername) -}}
-{{- range $topic, $topic_config := $config.topics }}
-{{ $topic }}.storage.replication.factor: {{ $topic_config.replicationFactor | default $global.replicationFactor }}
+{{- $topic_configs := $config.topics | default $global.topics }}
+{{- range $topic, $topic_defaults := $global.topics }}
+{{- $topic_config := index $topic_configs $topic | default $topic_defaults }}
+{{ $topic }}.storage.replication.factor: {{ $topic_config.replicationFactor | default $topic_defaults.replicationFactor }}
 {{ $topic }}.storage.topic: {{ $topic_config.topic | default (printf "%s-%s" $topic_prefix $topic) }}
 {{- end }}
 {{- end }}

charts/kafka-connect/values.yaml

@@ -1,5 +1,4 @@
 global:
-  replicationFactor: 3
   replicas: 1
   configTopicPrefix: __connect-cluster
   version: 3.8.0
@@ -10,6 +9,13 @@ global:
   secretStore: aws-secretsmanager
   secretStoreKind: ClusterSecretStore
   refreshInterval: 1h
+  topics:
+    config:
+      replicationFactor: 3
+    offset:
+      replicationFactor: 3
+    status:
+      replicationFactor: 3
 
 image: sionsmith/oso-strimzi-kafka-operator-iam-auth:0.38.0-kafka-3.6.0-aws-latest