use string converter for better readability in kowl and other tools

BACK-2504
tidepool-org · Mar 27, 2024 · cf207f5 · cf207f5
1 parent ab548c2
commit cf207f5
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/charts/tidepool/charts/data/templates/8-care-partner-alerts-kafka-connector.yaml b/charts/tidepool/charts/data/templates/8-care-partner-alerts-kafka-connector.yaml
@@ -15,10 +15,10 @@ spec:
     connection.uri: {{ .Values.global.kafka.connect.mongoConnectionUri }}
     copy.existing: true
     database: data
-    key.converter: org.apache.kafka.connect.json.JsonConverter
+    key.converter: org.apache.kafka.connect.storage.StringConverter
     key.converter.schemas.enable: false
     topic.prefix: {{ .Release.Namespace }}
-    value.converter: org.apache.kafka.connect.json.JsonConverter
+    value.converter: org.apache.kafka.connect.storage.StringConverter
     value.converter.schemas.enable: false
     heartbeat.interval.ms: {{ .Values.global.kafka.connect.mongoHeartbeatIntervalMs }}
     heartbeat.topic.name: {{ .Release.Namespace }}-{{ .Values.global.kafka.connect.clusterName }}-heartbeat

diff --git a/charts/tidepool/charts/data/templates/8-device-data-kafka-connector.yaml b/charts/tidepool/charts/data/templates/8-device-data-kafka-connector.yaml
@@ -15,7 +15,7 @@ spec:
     connection.uri: {{ .Values.global.kafka.connect.mongoConnectionUri }}
     copy.existing: false
     database: data
-    key.converter: org.apache.kafka.connect.json.JsonConverter
+    key.converter: org.apache.kafka.connect.storage.StringConverter
     key.converter.schemas.enable: false
     pipeline: >-
       [
@@ -28,7 +28,7 @@ spec:
       ]
     topic.prefix: {{ .Release.Namespace }}
     topic.suffix: "alerts"
-    value.converter: org.apache.kafka.connect.json.JsonConverter
+    value.converter: org.apache.kafka.connect.storage.StringConverter
     value.converter.schemas.enable: false
     heartbeat.interval.ms: {{ .Values.global.kafka.connect.mongoHeartbeatIntervalMs }}
     heartbeat.topic.name: {{ .Release.Namespace }}-{{ .Values.global.kafka.connect.clusterName }}-heartbeat