kafkactl
kafkactl copied to clipboard
No configuration for consumer session timeout
Hello,
There are cases where the client needs to increase consumer timeout. The default value set in the sarama library is 10 seconds which might not be enough for example sometimes rebalancing a group takes a while resulting in a timeout.
We can easily use the requestTimeout
set in the configuration for all of the timeouts.
If this is a valid idea to you I can create a pull request.
Hi @tparsa
exposing additional timeout configuration from sarama is a valid idea. Which config parameter are you talking about. This one here? https://github.com/Shopify/sarama/blob/main/config.go#L285
Regards, Drk
Hello @d-rk
Yes, that's the specific timeout that I needed to change. But generally, we can add all of the configurations that the sarama
library can use.