What's Changed
Allow to specify Redis Stream maxlen option in publisher:
@broker.publisher(stream=StreamSub("Output", maxlen=10))
async def on_input_data():
....- chore: bump version by @Lancetnik in #1198
- Update Release Notes for 0.4.2 by @faststream-release-notes-updater in #1199
- Add missing API documentation for apply_pattern by @kumaranvpl in #1201
- chore: polishing by @davorrunje in #1203
- Comment out retry and timeout in a confluent test by @kumaranvpl in #1207
- Commit offsets only if auto_commit is True by @kumaranvpl in #1208
- Add a CI job to check for missed docs changes by @kumaranvpl in #1217
- fix: inconsistent NATS publisher signature by @Lancetnik in #1218
- Upgrade packages by @davorrunje in #1226
- chore: bump dawidd6/action-download-artifact from 3.0.0 to 3.1.1 by @dependabot in #1239
- chore: bump dependencies by @Lancetnik in #1246
- feat (#1235): StreamSub maxlen parameter by @Lancetnik in #1245
- fix (#1234): correct FastAPI path passing, fix typehints by @Lancetnik in #1236
- fix (#1231): close RMQ while reconnecting by @Lancetnik in #1238
Full Changelog: 0.4.2...0.4.3