0.0.12

Various fixes & improvements

• feat: Bump confluent kafka to 1.6.1 (#51) by @lynnagara
• ci: Upgrade black version to 22.3.0 (#52) by @lynnagara

0.0.11

Various fixes & improvements

• Removed Generic payload from DLQ Policy (#49) by @rahul-kumar-saini
• export InvalidMessage from DLQ (#48) by @rahul-kumar-saini

0.0.10

Various fixes & improvements

• Dead Letter Queue (#47) by @rahul-kumar-saini
• Added an example for Arroyo usage. (#44) by @rahul-kumar-saini

0.0.9

Various fixes & improvements

• ref(metrics): Add metrics for time spent polling and closing batch (#46) by @nikhars

0.0.8

Various fixes & improvements

• chore(parallel_collect): Allow importing ParallelCollectStep (#43) by @nikhars

0.0.7

Various fixes & improvements

• perf(collect): Add ParallelCollect step (#41) by @nikhars

0.0.6

Various fixes & improvements

• Increase log level (#39) by @fpacifici
• feat(perf) Add latency metrics to the messages coming from the commit log (#38) by @fpacifici

0.0.5

• Number of processes in the multi-process poll metric added. Its key is
  transform.processes.

0.0.4

• Handle missing orig_message_ts header. Since all events in the pipeline produced using an older version of arroyo may not have the header yet, temporarily support a None value for orig_message_ts.

0.0.3

• No documented changes.