- 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`.