From 906f6b94fcdf4e8f94c36e2170bfda7e2f4e0439 Mon Sep 17 00:00:00 2001 From: Xavi Ramirez Date: Tue, 18 Jul 2017 19:53:25 +0000 Subject: [PATCH] Made ReadBurstLimit relative to read rate limit --- batchconsumer/consumer.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/batchconsumer/consumer.go b/batchconsumer/consumer.go index 650f422..4bac1e8 100644 --- a/batchconsumer/consumer.go +++ b/batchconsumer/consumer.go @@ -66,8 +66,8 @@ func withDefaults(config Config) Config { if config.ReadRateLimit == 0 { config.ReadRateLimit = 300 } - if config.ReadRateLimit == 0 { - config.ReadRateLimit = int(300 * 1.2) + if config.ReadBurstLimit == 0 { + config.ReadBurstLimit = int(float64(config.ReadRateLimit)*1.2 + 0.5) } if config.CheckpointFreq == 0 {