fix(DMVP-4835): Added key and timestamp to kafka connect backuped data

dasmeta · Aug 2, 2024 · c7aa3e3 · c7aa3e3
1 parent 85f589f
commit c7aa3e3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/charts/kafka-connect/templates/configmap.yaml b/charts/kafka-connect/templates/configmap.yaml
@@ -17,8 +17,8 @@ data:
         "flush.size": "{{ .Values.config.connector.gcs.flushSize }}",
         "gcs.credentials.path": "{{ .Values.config.connector.gcs.credentialsPath }}",
         "format.output.type": "jsonl",
-        "format.output.envelope": false,
-        "format.output.fields": "value",
+        "format.output.envelope": true,
+        "format.output.fields": "key,value,timestamp",
         "_format.output.fields": "key,value,offset,timestamp,headers",
         "file.name.prefix": "raw/",
         "file.compression.type": "gzip",