fix(dlq): Make InvalidMessage pickleable

getsentry / arroyo

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

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

Apache License 2.0

39 stars 6 forks source link

Closed nikhars closed 9 months ago

nikhars commented 9 months ago

We saw a crash in the ingest spans consumer because InvalidMessage is unpickleable. Make it pickleable to avoid the crash.