From 3369eeb920ae856ac5358c933087bfa1994f2413 Mon Sep 17 00:00:00 2001 From: Praveen raj Mani Date: Fri, 24 Nov 2023 22:37:38 +0530 Subject: [PATCH] Relax batch size limit for kafka events (#18513) Fixes #18490 --- internal/event/target/kafka.go | 5 ----- 1 file changed, 5 deletions(-) diff --git a/internal/event/target/kafka.go b/internal/event/target/kafka.go index 21cd9166d..0e15113e6 100644 --- a/internal/event/target/kafka.go +++ b/internal/event/target/kafka.go @@ -75,8 +75,6 @@ const ( EnvKafkaClientTLSKey = "MINIO_NOTIFY_KAFKA_CLIENT_TLS_KEY" EnvKafkaVersion = "MINIO_NOTIFY_KAFKA_VERSION" EnvKafkaBatchSize = "MINIO_NOTIFY_KAFKA_BATCH_SIZE" - - maxBatchLimit = 100 ) // KafkaArgs - Kafka target arguments. @@ -131,9 +129,6 @@ func (k KafkaArgs) Validate() error { if k.QueueDir == "" { return errors.New("batch should be enabled only if queue dir is enabled") } - if k.BatchSize > maxBatchLimit { - return fmt.Errorf("batch limit should not exceed %d", maxBatchLimit) - } } return nil }