fix: batch byte size limit default config error

Trendyol · Dec 26, 2023 · 12b1dd5 · 12b1dd5
1 parent a96c749
commit 12b1dd5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/config/config.go b/config/config.go
@@ -61,7 +61,7 @@ func (c *Connector) ApplyDefaults() {
 		c.Kafka.ProducerBatchSize = 2000
 	}
 
-	if c.Kafka.ProducerBatchBytes == 0 {
+	if c.Kafka.ProducerBatchBytes == nil {
 		c.Kafka.ProducerBatchBytes = helpers.ResolveUnionIntOrStringValue("10mb")
 	}