2.7.1

Various fixes & improvements

• fix(run_task): Fix bug where join() would not actually wait for tasks (#190) by @untitaker

2.7.0

Various fixes & improvements

• fix(filter-strategy): Options to commit filtered messages, take 2 (#185) by @untitaker
• fix: Fix multiprocessing join (#189) by @lynnagara
• build: Run CI on Python 3.11 (#188) by @lynnagara

2.6.0

Various fixes & improvements

• feat: Configurable strategy join timeout (#187) by @lynnagara
• feat: Log exception if processing strategy exists on assignment (#186) by @lynnagara

2.5.3

Various fixes & improvements

• fix(decoder): Fix importing optional dependencies (#184) by @lynnagara

2.5.2

• No documented changes.

2.5.1

Various fixes & improvements

• fix(produce): Fix closing next step (#183) by @lynnagara
• fix(reduce): Ensure next step is properly closed (#182) by @lynnagara
• ref: Don't alias ProcessingStrategy as ProcessingStep (#181) by @lynnagara
• ref: upgrade isort to work around poetry breakage (#179) by @asottile-sentry
• fix: Documentation typos (#178) by @markstory
• build: Split avro, json, msgpack into separate modules (#176) by @lynnagara

2.5.0

Various fixes & improvements

• feat: Remove CollectStep and ParallelCollectStep (#173) by @lynnagara
• feat(reduce): Record arroyo.strategies.reduce.batch_time (#175) by @lynnagara
• docs: Add decoders section (#174) by @lynnagara
• build: Make json, msgpack and avro optional dependencies (#172) by @lynnagara

2.4.0

Various fixes & improvements

• feat(serializers): Add more decoders (#171) by @lynnagara
• feat(reduce): Support greater flexibility in initial value (#170) by @lynnagara
• auto publish to internal pypi on release (#169) by @asottile-sentry
• feat: Remove support for cooperative-sticky partition assignment strategy (#168) by @lynnagara

2.3.1

Various fixes & improvements

• ref(decoder): Remove dead code (#167) by @lynnagara
• ref(commit_policy): Improve performance of commit policy (#162) by @untitaker
• feat(decoders): Json decoder can be used without schema (#166) by @lynnagara

2.3.0

Various fixes & improvements

• feat: Add Reduce strategy (#157) by @lynnagara
• ref: Remove Position and stop passing timestamps to the commit function (#165) by @lynnagara
• feat: Add a schema validation strategy (#154) by @lynnagara
• fix: Ensure Collect/ParallelCollect properly calls next_step methods (#163) by @lynnagara
• feat: Remove the BatchProcessingStrategy and AbstractBatchWorker (#164) by @lynnagara
• test: Fix streamprocessor tests (#160) by @lynnagara
• docs: Call out the run task strategy (#161) by @lynnagara
• fix: RunTaskWithMultiprocessing handles MessageRejected from subsequent steps (#158) by @lynnagara
• ref: Improve typing of CommitOffsets strategy (#159) by @lynnagara