diff --git a/batchconsumer/consumer.go b/batchconsumer/consumer.go index f43ef05..35f4ddc 100644 --- a/batchconsumer/consumer.go +++ b/batchconsumer/consumer.go @@ -63,8 +63,9 @@ func withDefaults(config Config) Config { config.DeployEnv = "unknown-env" } + // Not totally clear we need this rate limit. The KCL may do rate limiting for us. if config.ReadRateLimit == 0 { - config.ReadRateLimit = 300 + config.ReadRateLimit = 1000 } if config.ReadBurstLimit == 0 { config.ReadBurstLimit = int(float64(config.ReadRateLimit)*1.2 + 0.5)