MyFavMirrors/minio
1
0
Fork 0
mirror of https://github.com/minio/minio.git synced 2025-02-02 17:35:58 -05:00
Code Issues Packages Projects Releases Wiki Activity

Relax batch size limit for kafka events (#18513)

Browse Source 
Fixes #18490
This commit is contained in:
Praveen raj Mani 2023-11-24 22:37:38 +05:30 committed by GitHub
parent 9032f49f25
commit 3369eeb920
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
internal/event/target/kafka.go
View File

@ -75,8 +75,6 @@ const (
EnvKafkaClientTLSKey = "MINIO_NOTIFY_KAFKA_CLIENT_TLS_KEY" EnvKafkaClientTLSKey = "MINIO_NOTIFY_KAFKA_CLIENT_TLS_KEY"
EnvKafkaVersion = "MINIO_NOTIFY_KAFKA_VERSION" EnvKafkaVersion = "MINIO_NOTIFY_KAFKA_VERSION"
EnvKafkaBatchSize = "MINIO_NOTIFY_KAFKA_BATCH_SIZE" EnvKafkaBatchSize = "MINIO_NOTIFY_KAFKA_BATCH_SIZE"
maxBatchLimit = 100
) )
// KafkaArgs - Kafka target arguments. // KafkaArgs - Kafka target arguments.
@ -131,9 +129,6 @@ func (k KafkaArgs) Validate() error {
if k.QueueDir == "" { if k.QueueDir == "" {
return errors.New("batch should be enabled only if queue dir is enabled") 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 return nil
} }