From 6d1608ba5d16cb57dcd121b8ae1b383fd4cf13b5 Mon Sep 17 00:00:00 2001
From: lostlevels <lostlevels@users.noreply.github.com>
Date: Tue, 26 May 2026 06:27:57 -0700
Subject: [PATCH] [BACK-3938] Add patient_deletions source connector.

---
 charts/tidepool/Chart.yaml                    |  2 +-
 ...ient-deletions-source-kafka-connector.yaml | 26 +++++++++++++++++++
 2 files changed, 27 insertions(+), 1 deletion(-)
 create mode 100644 charts/tidepool/charts/clinic/templates/5-patient-deletions-source-kafka-connector.yaml

diff --git a/charts/tidepool/Chart.yaml b/charts/tidepool/Chart.yaml
index 53542310..e6357ef5 100644
--- a/charts/tidepool/Chart.yaml
+++ b/charts/tidepool/Chart.yaml
@@ -1,7 +1,7 @@
 apiVersion: v2
 description: A Helm chart for Tidepool
 name: tidepool
-version: 0.24.6
+version: 0.24.7
 maintainers:
   - name: Todd Kazakov
     email: todd@tidepool.org
diff --git a/charts/tidepool/charts/clinic/templates/5-patient-deletions-source-kafka-connector.yaml b/charts/tidepool/charts/clinic/templates/5-patient-deletions-source-kafka-connector.yaml
new file mode 100644
index 00000000..0c25d584
--- /dev/null
+++ b/charts/tidepool/charts/clinic/templates/5-patient-deletions-source-kafka-connector.yaml
@@ -0,0 +1,26 @@
+{{ if .Values.global.kafka.connect.enabled }}
+apiVersion: kafka.strimzi.io/v1beta2
+kind: KafkaConnector
+metadata:
+  labels:
+    app: patient-deletions-source
+    strimzi.io/cluster: {{ .Release.Namespace }}-{{ .Values.global.kafka.connect.clusterName }}
+  name: patient-deletions-source
+  namespace: {{ .Release.Namespace }}
+spec:
+  class: com.mongodb.kafka.connect.MongoSourceConnector
+  config:
+    change.stream.full.document: updateLookup
+    collection: patient_deletions
+    connection.uri: {{ .Values.global.kafka.connect.mongoConnectionUri }}
+    copy.existing: false
+    database: clinic
+    key.converter: org.apache.kafka.connect.json.JsonConverter
+    key.converter.schemas.enable: false
+    topic.prefix: {{ .Release.Namespace }}
+    value.converter: org.apache.kafka.connect.json.JsonConverter
+    value.converter.schemas.enable: false
+    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 }}