feat: increase batch byte limit default 10kb to 10mb

Trendyol · Apr 25, 2023 · 2a1ec1c · 2a1ec1c
1 parent d71414f
commit 2a1ec1c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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
@@ -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"`