What's Changed

Add support for explicit partition assignment in aiokafka KafkaBroker (special thanks to @spataphore1337):

from faststream import FastStream
from faststream.kafka import KafkaBroker, TopicPartition

broker = KafkaBroker()

topic_partition_fisrt = TopicPartition("my_topic", 1)
topic_partition_second = TopicPartition("my_topic", 2)

@broker.subscribe(partitions=[topic_partition_fisrt, topic_partition_second])
async def some_consumer(msg):
   ...

• Update Release Notes for 0.5.4 by @faststream-release-notes-updater in https://github.com/airtai/faststream/pull/1421
• feature: manual partition assignment to Kafka by @spataphore1337 in https://github.com/airtai/faststream/pull/1422
• Chore/update deps by @Lancetnik in https://github.com/airtai/faststream/pull/1429
• Fix/correct dynamic subscriber registration by @Lancetnik in https://github.com/airtai/faststream/pull/1433
• chore: bump version by @Lancetnik in https://github.com/airtai/faststream/pull/1435

Full Changelog: https://github.com/airtai/faststream/compare/0.5.4...0.5.5