fix: Cleanup backpressure state between assignments

getsentry / arroyo

A library to build streaming applications that consume from and produce to Kafka.

https://getsentry.github.io/arroyo/

Apache License 2.0

41 stars 7 forks source link

fix: Cleanup backpressure state between assignments #299

Closed lynnagara closed 11 months ago

lynnagara commented 11 months ago

This is a fix for inc-552

It caused a bug where a message could be submitted to the processing strategy twice immediately after assignment if there was backpressure before the rebalance.