Fixes
- fix: include inflight message count in polling backpressure logic (#836)
- fix: message loss on closing or partitions revoked (#827) fixes (#826)
- fix: unbounded retry queue growth preventing polling from being throttled and leading to OOM (#834) fixes (#832, #817)
Note
#836 introduces a change in how buffer size is calculated as now inflight messages are counted as part of buffer size - so behaviour of existing applications may change and pausing of consumer happen sooner.
GH Generated
What's Changed
- fix for message loss for issue 826 by @sangreal in #827
- chore: update repo by service bot by @ConfluentJenkins in #813
- Fix retry queue implementation to prevent unbounded growth by @rkolesnev in #834
- Fix buffer size include in flight messages in backpressure calculation logic by @rkolesnev in #836
Full Changelog: 0.5.3.1...0.5.3.2