- fix(commit_policy): Calculate elapsed timerange correctly (155) by untitaker - ref: Remove dead code (153) by lynnagara - feat(Collect) Attempt to redesign the Collector step (127) by fpacifici
2.1.0
Various fixes & improvements
- feat: Collect / ParallelCollect supports a next step (149) by lynnagara - feat: Add RunTaskWithMultiprocessing strategy (152) by lynnagara - feat: Add replace() method to message (151) by lynnagara - feat: Death to the consumer strategy factory (150) by lynnagara - feat: Add RunTask strategy (147) by lynnagara
2.0.0
Various fixes & improvements
- feat: Split the Message interface to better support batching steps (134) by lynnagara - feat: Remove BatchProcessingStrategyFactory from Arroyo (138) by lynnagara - docs: Add docstring for MessageRejected (146) by lynnagara - feat: Increase log level during consumer shutdown (144) by lynnagara - feat: Remove ProduceAndCommit (145) by lynnagara
1.2.0
Various fixes & improvements
- feat: Introduce separate commit strategy (140) by lynnagara - feat: Mark ConsumerStrategyFactory/KafkaConsumerStrategyFactory deprecated (139) by lynnagara - docs: Update DLQ docs (136) by lynnagara - fix: Compute offset deltas for commit policy [SNS-1863] (135) by untitaker - fix: Make Position pickleable (129) by lynnagara - feat: Avoid storing entire messages in RunTaskInThreads (133) by lynnagara - feat: Avoid storing entire messages in the produce step (132) by lynnagara - test: Split the collect and transform tests into separate files (130) by lynnagara - test: Simplify the commit codec test (131) by lynnagara
1.1.0
Various fixes & improvements
- Update actions/upload-artifact to v3.1.1 (128) by mattgauntseo-sentry - feat: Add stream processor metrics (124) by lynnagara - docs: Remove comment about asyncio in architecture (121) by lynnagara - docs: Remove the big pointless black square (120) by lynnagara - docs: Remove invalid release number (122) by lynnagara - feat: Make commit policy a required argument (116) by lynnagara - docs(autodocs) Adds autodoc support and import docstrings in the sphinx doc (118) by fpacifici - Add architecture page (117) by fpacifici - feat: Add RunTaskInThreads strategy (111) by lynnagara - feat: Add produce step to library (109) by lynnagara - ref: Rename variable (115) by lynnagara
1.0.7
Various fixes & improvements
- ref: Move strategies out of streaming module (114) by lynnagara - feat: Add Message.position_to_commit (113) by lynnagara - feat: Simplify example (112) by lynnagara - feat: Add deprecation comment on batching strategies (110) by lynnagara - build: Run CI on Python 3.10 (108) by lynnagara - build: Include requirements.txt in source distribution (107) by lynnagara