Der S3-Connector schreib JSON

diff --git a/s3-sink-connector.json b/s3-sink-connector.json
index fceae82..15f3686 100644 (file)
--- 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"