franz-go icon indicating copy to clipboard operation
franz-go copied to clipboard

There is no option to set max.poll.interval.ms

Open GRbit opened this issue 2 months ago • 0 comments

First of all, thank you very much for your project. It's very nice to have a good Kafka consumer that respects interfaces (compared to std confluent library) and also gives a better performance. Impressive work!

Coming to the problem, I need to set manually the max.poll.interval.ms with the consumer I use, but I see no option for it.

Are there any plans for implementing this functionality in the future? Are there any workarounds to achieve the same result?

If you want to have this feature probably I can help, but I'll need some help finding documentation on how it should be implemented, so any help is very much appreciated.

UPD: I find CommitUncommittedOffsets function VERY useful, what a nice thing to have! Still, I can not use it, because without max.poll.interval.ms the only approach that is left to my case is to poll every (SessionTimout/2) seconds while I'm processing collected records. Otherwise, the broker will consider the consumer frozen and will trigger rebalance which is quite a boomer.

GRbit avatar Apr 17 '24 13:04 GRbit