Faststream

What's Changed

Add RedisStream batch size option

python
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 https://github.com/airtai/faststream/pull/1247
* docs: add manual run section by Lancetnik in https://github.com/airtai/faststream/pull/1249
* feat (1252): respect Redis StreamSub last_id with consumer group by Lancetnik in https://github.com/airtai/faststream/pull/1256
* fix: correct Redis consumer group behavior by Lancetnik in https://github.com/airtai/faststream/pull/1258
* feat: add Redis Stream max_records option by Lancetnik in https://github.com/airtai/faststream/pull/1259


**Full Changelog**: https://github.com/airtai/faststream/compare/0.4.3...0.4.4

What's Changed

Allow to specify **Redis Stream** maxlen option in publisher:

python
broker.publisher(stream=StreamSub("Output", maxlen=10))
async def on_input_data():
....


* chore: bump version by Lancetnik in https://github.com/airtai/faststream/pull/1198
* Update Release Notes for 0.4.2 by faststream-release-notes-updater in https://github.com/airtai/faststream/pull/1199
* Add missing API documentation for apply_pattern by kumaranvpl in https://github.com/airtai/faststream/pull/1201
* chore: polishing by davorrunje in https://github.com/airtai/faststream/pull/1203
* Comment out retry and timeout in a confluent test by kumaranvpl in https://github.com/airtai/faststream/pull/1207
* Commit offsets only if auto_commit is True by kumaranvpl in https://github.com/airtai/faststream/pull/1208
* Add a CI job to check for missed docs changes by kumaranvpl in https://github.com/airtai/faststream/pull/1217
* fix: inconsistent NATS publisher signature by Lancetnik in https://github.com/airtai/faststream/pull/1218
* Upgrade packages by davorrunje in https://github.com/airtai/faststream/pull/1226
* chore: bump dawidd6/action-download-artifact from 3.0.0 to 3.1.1 by dependabot in https://github.com/airtai/faststream/pull/1239
* chore: bump dependencies by Lancetnik in https://github.com/airtai/faststream/pull/1246
* feat (1235): StreamSub maxlen parameter by Lancetnik in https://github.com/airtai/faststream/pull/1245
* fix (1234): correct FastAPI path passing, fix typehints by Lancetnik in https://github.com/airtai/faststream/pull/1236
* fix (1231): close RMQ while reconnecting by Lancetnik in https://github.com/airtai/faststream/pull/1238


**Full Changelog**: https://github.com/airtai/faststream/compare/0.4.2...0.4.3

What's Changed

Bug fixes

* fix: correct RMQ Topic testing routing by Lancetnik in https://github.com/airtai/faststream/pull/1196
* fix 1191: correct RMQ ssl default port by Lancetnik in https://github.com/airtai/faststream/pull/1195
* fix 1143: ignore Depends in AsyncAPI by Lancetnik in https://github.com/airtai/faststream/pull/1197


**Full Changelog**: https://github.com/airtai/faststream/compare/0.4.1...0.4.2

What's Changed

Bug fixes

* Fix: use FastAPI overrides in subscribers by Lancetnik in https://github.com/airtai/faststream/pull/1189
* Handle confluent consumer commit failure by kumaranvpl in https://github.com/airtai/faststream/pull/1193

Documentation

* Include Confluent in home and features pages by kumaranvpl in https://github.com/airtai/faststream/pull/1186
* Use pydantic model for publishing in docs example by kumaranvpl in https://github.com/airtai/faststream/pull/1187


**Full Changelog**: https://github.com/airtai/faststream/compare/0.4.0...0.4.1

New Contributors
* saroz014 made their first contribution in https://github.com/airtai/faststream/pull/1154

**Full Changelog**: https://github.com/airtai/faststream/compare/0.3.13...0.4.0

What's Changed

This is a **preview version** of 0.4.0 release introducing support for Confluent-based Kafka broker.

Here's a simplified code example demonstrating how to establish a connection to Kafka using FastStream's KafkaBroker module:
python
from faststream import FastStream
from faststream.confluent import KafkaBroker

broker = KafkaBroker("localhost:9092")
app = FastStream(broker)

broker.subscriber("in-topic")
broker.publisher("out-topic")
async def handle_msg(user: str, user_id: int) -> str:
return f"User: {user_id} - {user} registered"


Changes

* Add support for confluent python lib by kumaranvpl in https://github.com/airtai/faststream/pull/1042


**Full Changelog**: https://github.com/airtai/faststream/compare/0.3.13...0.4.0rc0