What's Changed
Add RedisStream batch size option
@broker.subscriber(stream=StreamSub("input", batch=True, max_records=3))
async def on_input_data(msgs: list[str]):
assert len(msgs) <= 3- Update Release Notes for 0.4.3 by @faststream-release-notes-updater in #1247
- docs: add manual run section by @Lancetnik in #1249
- feat (#1252): respect Redis StreamSub last_id with consumer group by @Lancetnik in #1256
- fix: correct Redis consumer group behavior by @Lancetnik in #1258
- feat: add Redis Stream max_records option by @Lancetnik in #1259
Full Changelog: 0.4.3...0.4.4