From: Kai Moritz <kai@juplo.de>
Date: Fri, 26 Apr 2024 17:53:43 +0000 (+0200)
Subject: Der S3-Connector schreib JSON
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=7077e864d88bd254e87db565e84b901f94f77bea;p=demos%2Fkafka%2Ftraining

Der S3-Connector schreib JSON
---

diff --git a/s3-sink-connector.json b/s3-sink-connector.json
index fceae82..15f3686 100644
--- a/s3-sink-connector.json
+++ b/s3-sink-connector.json
@@ -11,7 +11,7 @@
     "flush.size": "1000",
     "storage.class": "io.confluent.connect.s3.storage.S3Storage",
     "store.url": "http://minio:9000",
-    "format.class": "io.confluent.connect.s3.format.avro.AvroFormat",
+    "format.class": "io.confluent.connect.s3.format.json.JsonFormat",
     "schema.generator.class": "io.confluent.connect.storage.hive.schema.DefaultSchemaGenerator",
     "partitioner.class": "io.confluent.connect.storage.partitioner.DefaultPartitioner",
     "schema.compatibility": "NONE"