fix(filter): Handle MessageRejected correctly (INC-584)

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(filter): Handle MessageRejected correctly (INC-584) #313

Closed untitaker closed 9 months ago

untitaker commented 9 months ago

When joining a FilterStep, it can happen that the upstream strategy raises MessageRejected. We need to deal with that somehow, and in this PR I'm just suppressing that exception.

Also fix a severe bug where MessageRejected was propagated through submit(), but the MessageRejected was for the wrong message, causing double-submission of messages.