From a1cfcca530573791663875ce9a6714b22a24097b Mon Sep 17 00:00:00 2001 From: Behrooz Shafiee Date: Thu, 18 Jan 2018 14:12:15 -0500 Subject: [PATCH] changed Fetch.default value from 32KB to 1MB --- config.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/config.go b/config.go index e4ff680f2..29ea5c2b3 100644 --- a/config.go +++ b/config.go @@ -175,7 +175,7 @@ type Config struct { // Equivalent to the JVM's `fetch.min.bytes`. Min int32 // The default number of message bytes to fetch from the broker in each - // request (default 32768). This should be larger than the majority of + // request (default 1MB). This should be larger than the majority of // your messages, or else the consumer will spend a lot of time // negotiating sizes and not actually consuming. Similar to the JVM's // `fetch.message.max.bytes`. @@ -292,7 +292,7 @@ func NewConfig() *Config { c.Producer.Return.Errors = true c.Consumer.Fetch.Min = 1 - c.Consumer.Fetch.Default = 32768 + c.Consumer.Fetch.Default = 1024 * 1024 c.Consumer.Retry.Backoff = 2 * time.Second c.Consumer.MaxWaitTime = 250 * time.Millisecond c.Consumer.MaxProcessingTime = 100 * time.Millisecond