From 918652d1f26bb5a5997adf1f1fd9c8fc48f96b89 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Fri, 26 Apr 2024 09:55:52 +0200
Subject: [PATCH] Flush der S3-Objekte nach 1000 Nachrichten oder 3 Sekunden
---
s3-sink-connector.json | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/s3-sink-connector.json b/s3-sink-connector.json
index d85eba9e..fceae823 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",
--
2.20.1