From: Kai Moritz <kai@juplo.de>
Date: Fri, 26 Apr 2024 07:55:52 +0000 (+0200)
Subject: Flush der S3-Objekte nach 1000 Nachrichten oder 3 Sekunden
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=918652d1f26bb5a5997adf1f1fd9c8fc48f96b89;p=demos%2Fkafka%2Ftraining

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
--- 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",