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 }