Add merge plans CDC source (#294)

tidepool-org · Oct 7, 2024 · 050e6c2 · 050e6c2
1 parent dadcecf
commit 050e6c2
Showing 1 changed file with 24 additions and 0 deletions.
diff --git a/charts/tidepool/charts/clinic/templates/5-merge-plans-source-kafka-connector.yaml b/charts/tidepool/charts/clinic/templates/5-merge-plans-source-kafka-connector.yaml
@@ -0,0 +1,24 @@
+{{ if .Values.global.kafka.connect.enabled }}
+apiVersion: kafka.strimzi.io/v1beta2
+kind: KafkaConnector
+metadata:
+  labels:
+    app: merge-plans-source
+    strimzi.io/cluster: {{ .Release.Namespace }}-{{ .Values.global.kafka.connect.clusterName }}
+  name: merge-plans-source
+  namespace: {{ .Release.Namespace }}
+spec:
+  class: com.mongodb.kafka.connect.MongoSourceConnector
+  config:
+    change.stream.full.document: updateLookup
+    collection: merge_plans
+    connection.uri: {{ .Values.global.kafka.connect.mongoConnectionUri }}
+    database: clinic
+    topic.prefix: {{ .Release.Namespace }}
+    output.json.formatter: com.mongodb.kafka.connect.source.json.formatter.ExtendedJson
+    value.converter: org.apache.kafka.connect.storage.StringConverter
+    key.converter: org.apache.kafka.connect.storage.StringConverter
+    heartbeat.interval.ms: {{ .Values.global.kafka.connect.mongoHeartbeatIntervalMs }}
+    heartbeat.topic.name: {{ .Release.Namespace }}-{{ .Values.global.kafka.connect.clusterName }}-heartbeat
+  tasksMax: {{ .Values.global.kafka.connect.sourceTasksMax | int }}
+{{- end }}