Flush der S3-Objekte nach 1000 Nachrichten oder 3 Sekunden

diff --git a/s3-sink-connector.json b/s3-sink-connector.json
index d85eba9..fceae82 100644 (file)
--- a/s3-sink-connector.json
+++ b/s3-sink-connector.json
@@ -6,7 +6,9 @@
     "topics": "test",
     "s3.bucket.name": "juplo",
     "s3.part.size": "5242880",
-    "flush.size": "3",
+    "timezone": "Europe/Berlin",
+    "rotate.schedule.interval.ms": "3000",
+    "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",