Disable copy on start for topics where consumer groups cannot handle …

…the initial copy events (#299)
tidepool-org · Oct 16, 2024 · 4806fff · 4806fff
1 parent a832baf
commit 4806fff
Show file tree

Hide file tree

Showing 7 changed files with 7 additions and 7 deletions.
diff --git a/charts/tidepool/charts/clinic/templates/5-clinicians-source-kafka-connector.yaml b/charts/tidepool/charts/clinic/templates/5-clinicians-source-kafka-connector.yaml
@@ -13,7 +13,7 @@ spec:
     change.stream.full.document: updateLookup
     collection: clinicians
     connection.uri: {{ .Values.global.kafka.connect.mongoConnectionUri }}
-    copy.existing: true
+    copy.existing: false
     database: clinic
     key.converter: org.apache.kafka.connect.json.JsonConverter
     key.converter.schemas.enable: false

diff --git a/charts/tidepool/charts/clinic/templates/5-clinics-source-kafka-connector.yaml b/charts/tidepool/charts/clinic/templates/5-clinics-source-kafka-connector.yaml
@@ -13,7 +13,7 @@ spec:
     change.stream.full.document: updateLookup
     collection: clinics
     connection.uri: {{ .Values.global.kafka.connect.mongoConnectionUri }}
-    copy.existing: true
+    copy.existing: false
     database: clinic
     key.converter: org.apache.kafka.connect.json.JsonConverter
     key.converter.schemas.enable: false

diff --git a/charts/tidepool/charts/clinic/templates/5-migrations-source-kafka-connector.yaml b/charts/tidepool/charts/clinic/templates/5-migrations-source-kafka-connector.yaml
@@ -13,7 +13,7 @@ spec:
     change.stream.full.document: updateLookup
     collection: migrations
     connection.uri: {{ .Values.global.kafka.connect.mongoConnectionUri }}
-    copy.existing: true
+    copy.existing: false
     database: clinic
     key.converter: org.apache.kafka.connect.json.JsonConverter
     key.converter.schemas.enable: false

diff --git a/charts/tidepool/charts/clinic/templates/5-patients-source-kafka-connector.yaml b/charts/tidepool/charts/clinic/templates/5-patients-source-kafka-connector.yaml
@@ -13,7 +13,7 @@ spec:
     change.stream.full.document: updateLookup
     collection: patients
     connection.uri: {{ .Values.global.kafka.connect.mongoConnectionUri }}
-    copy.existing: true
+    copy.existing: false
     pipeline: '[ {$project: {"fullDocument.summary": 0}} ]'
     startup.mode.copy.existing.pipeline: '[ {$project: {"fullDocument.summary": 0}} ]'
     database: clinic

diff --git a/...ts/tidepool/charts/clinic/templates/5-redox-scheduled-reports-source-kafka-connector.yaml b/...ts/tidepool/charts/clinic/templates/5-redox-scheduled-reports-source-kafka-connector.yaml
@@ -13,7 +13,7 @@ spec:
     change.stream.full.document: updateLookup
     collection: scheduledSummaryAndReportsOrders
     connection.uri: {{ .Values.global.kafka.connect.mongoConnectionUri }}
-    copy.existing: true
+    copy.existing: false
     database: clinic
     topic.prefix: {{ .Release.Namespace }}
     output.json.formatter: com.mongodb.kafka.connect.source.json.formatter.ExtendedJson

diff --git a/charts/tidepool/charts/clinic/templates/5-redox-source-kafka-connector.yaml b/charts/tidepool/charts/clinic/templates/5-redox-source-kafka-connector.yaml
@@ -13,7 +13,7 @@ spec:
     change.stream.full.document: updateLookup
     collection: redox
     connection.uri: {{ .Values.global.kafka.connect.mongoConnectionUri }}
-    copy.existing: true
+    copy.existing: false
     database: clinic
     topic.prefix: {{ .Release.Namespace }}
     output.json.formatter: com.mongodb.kafka.connect.source.json.formatter.ExtendedJson

diff --git a/charts/tidepool/charts/data/templates/8-summary-kafka-connector.yaml b/charts/tidepool/charts/data/templates/8-summary-kafka-connector.yaml
@@ -15,7 +15,7 @@ spec:
     change.stream.full.document: updateLookup
     collection: summary
     connection.uri: {{ .Values.global.kafka.connect.mongoConnectionUri }}
-    copy.existing: true
+    copy.existing: false
     database: data
     key.converter: org.apache.kafka.connect.json.JsonConverter
     key.converter.schemas.enable: false