Merge pull request #107 from dasmeta/DMVP-4835-kafka-connect

fix(DMVP-4835): Added key and timestamp to kafka connect backuped data
dasmeta · Aug 2, 2024 · 3c62a79 · 3c62a79
2 parents 85f589f + c7aa3e3
commit 3c62a79
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",