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 index 62d936b3..e1929f72 100644 --- 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 index 5dbc824e..d3da975d 100644 --- 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