From f581bb4f6e34f69bc1f6f8479b0f8e0e197cc614 Mon Sep 17 00:00:00 2001 From: Xavi Ramirez Date: Tue, 22 Aug 2017 18:37:47 +0000 Subject: [PATCH] Increased default read rate. --- batchconsumer/consumer.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/batchconsumer/consumer.go b/batchconsumer/consumer.go index c51ddd1..b48a1dd 100644 --- a/batchconsumer/consumer.go +++ b/batchconsumer/consumer.go @@ -53,9 +53,8 @@ func withDefaults(config Config) Config { config.BatchSize = 4 * 1024 * 1024 } - // Not totally clear we need this rate limit. The KCL may do rate limiting for us. if config.ReadRateLimit == 0 { - config.ReadRateLimit = 1000 + config.ReadRateLimit = 2500 } if config.ReadBurstLimit == 0 { config.ReadBurstLimit = int(float64(config.ReadRateLimit)*1.2 + 0.5)