From 918652d1f26bb5a5997adf1f1fd9c8fc48f96b89 Mon Sep 17 00:00:00 2001 From: Kai Moritz 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 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", -- 2.20.1