added config to set kafka topics as an array

charts/stream-processors/Chart.yaml

@@ -8,13 +8,13 @@ keywords:
   - kafka
   - strimzi kafka operator
   - stream processing
-version: 1.3.0
+version: 1.4.0
 annotations:
   artifacthub.io/recommendations: |
     - url: https://artifacthub.io/packages/helm/strimzi/strimzi-kafka-operator
     - url: https://artifacthub.io/packages/helm/prometheus-community/kube-prometheus-stack
   # When using the list of objects option the valid supported kinds are
   # added, changed, deprecated, removed, fixed and security.
   artifacthub.io/changes: |
-    - kind: changed
-      description: refreshed docs with latest helm-docs
+    - kind: added
+      description: config option `*.kafka.topics` to set the `KAFKA_TOPICS` env var from an array

charts/stream-processors/templates/_helpers.tpl

@@ -51,3 +51,8 @@ version label value
     {{- $tagAsString | quote }}
 {{- end }}
 {{- end }}
+
+{{- define "stream-processors.utils.joinListWithComma" -}}
+{{- $local := dict "first" true -}}
+{{- range $k, $v := . -}}{{- if not $local.first -}},{{- end -}}{{- $v -}}{{- $_ := set $local "first" false -}}{{- end -}}
+{{- end -}}

charts/stream-processors/templates/deployment.yaml

@@ -91,6 +91,18 @@ spec:
                 secretKeyRef:
                   name: {{ $.Values.strimziClusterName }}-cluster-ca-cert
                   key: ca.password
+            {{- with .kafka }}
+            {{- if .topics }}
+            - name: TOPICS
+              value: {{ include "stream-processors.utils.joinListWithComma" .topics }}
+            - name: TOPIC
+              value: {{ include "stream-processors.utils.joinListWithComma" .topics }}
+            - name: KAFKA_TOPICS
+              value: {{ include "stream-processors.utils.joinListWithComma" .topics }}
+            - name: KAFKA_TOPIC
+              value: {{ include "stream-processors.utils.joinListWithComma" .topics }}
+            {{- end }}
+            {{- end }}
             {{- if .container.env -}}
             {{- toYaml .container.env | default "" | nindent 12 }}
             {{- end }}

charts/stream-processors/values-test.yaml

@@ -63,6 +63,11 @@ processors:
         additionalLabels:
           release: prom
     replicaCount: 1
+    kafka:
+      topics:
+        - test-1
+        - test-2
+        - test-3
     container:
       image:
         registry: ghcr.io