- fix(dlq): Updated DLQ logic for ParallelTransformStep (61) by rahul-kumar-saini
0.0.18
Various fixes & improvements
- fix(tests): Make tests pass on M1 Macs (67) by mcannizz - test: Fix flaky test (66) by lynnagara - feat: Add flag to restore confluence kafka auto.offset.reset behavior (54) by mitsuhiko - feat(dlq): Added produce policy (57) by rahul-kumar-saini - feat(dlq): Revamped Invalid Message(s) Model (64) by rahul-kumar-saini
0.0.17
Various fixes & improvements
- feat: Avoid unnecessarily recreating processing strategy (62) by lynnagara - feat: Run CI on multiple Python versions (63) by lynnagara
0.0.16
Various fixes & improvements
- feat: Support incremental assignments in stream processor (58) by lynnagara
0.0.15
Various fixes & improvements
- feat(dlq): InvalidMessage exception refactored to handle multiple invalid messages (50) by rahul-kumar-saini - test: Fix flaky test (59) by lynnagara - feat(consumer): Wrap consumer strategy with DLQ if it exists (56) by rahul-kumar-saini