0.5.3.2 released

[Roman Kolesnev (rkolesnev)]

Version 0.5.3.2 released - https://github.com/confluentinc/parallel-consumer/releases/edit/0.5.3.2

Fixes

• fix: include inflight message count in polling backpressure logic (Fix buffer size include in flight messages in backpressure calculation logic #836)
• fix: message loss on closing or partitions revoked (fix for message loss for issue 826 #827) fixes (Message Loss Detected with frequent close and rebalancing #826)
• fix: unbounded retry queue growth preventing polling from being throttled and leading to OOM (Fix retry queue implementation to prevent unbounded growth #834) fixes ([OOM]Offset map reached to 75% pc-broker-poll thread would keep polling records lead to OOM #832, A possible memory leak in ShardManager.retryQueue ? #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 Martyn Ye (@sangreal) in fix for message loss for issue 826 #827
• chore: update repo by service bot by Confluent Jenkins Bot (@ConfluentJenkins) in chore: update repo by service bot #813
• Fix retry queue implementation to prevent unbounded growth by Roman Kolesnev (@rkolesnev) in Fix retry queue implementation to prevent unbounded growth #834
• Fix buffer size include in flight messages in backpressure calculation logic by Roman Kolesnev (@rkolesnev) in Fix buffer size include in flight messages in backpressure calculation logic #836

Full Changelog: 0.5.3.1...0.5.3.2