From 2a1ec1c7820b63670e38200e82339f8b937f4e70 Mon Sep 17 00:00:00 2001 From: Eray Date: Tue, 25 Apr 2023 16:18:50 +0300 Subject: [PATCH] feat: increase batch byte limit default 10kb to 10mb --- README.md | 2 +- config/config.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index a0cc359..7425fec 100644 --- a/README.md +++ b/README.md @@ -128,7 +128,7 @@ Check out on [go-dcp-client](https://github.com/Trendyol/go-dcp-client#configura | `kafka.collectionTopicMapping` | map[string]string | yes | | | | `kafka.brokers` | []string | yes | | | | `kafka.producerBatchSize` | integer | no | 2000 | | -| `kafka.producerBatchBytes` | integer | no | 10240 | | +| `kafka.producerBatchBytes` | integer | no | 10485760 | | | `kafka.producerBatchTickerDuration` | time.Duration | no | 10s | | | `kafka.readTimeout` | time.Duration | no | 30s | | | `kafka.writeTimeout` | time.Duration | no | 30s | | diff --git a/config/config.go b/config/config.go index 1dccdd7..a349304 100644 --- a/config/config.go +++ b/config/config.go @@ -17,7 +17,7 @@ type Kafka struct { RootCAPath string `yaml:"rootCAPath"` Brokers []string `yaml:"brokers"` ProducerBatchSize int `yaml:"producerBatchSize" default:"2000"` - ProducerBatchBytes int `yaml:"producerBatchBytes" default:"10240"` + ProducerBatchBytes int `yaml:"producerBatchBytes" default:"10485760"` ProducerBatchTickerDuration time.Duration `yaml:"producerBatchTickerDuration"` ReadTimeout time.Duration `yaml:"readTimeout"` WriteTimeout time.Duration `yaml:"writeTimeout"`