v0.5.5

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 #1421
• feature: manual partition assignment to Kafka by @spataphore1337 in #1422
• Chore/update deps by @Lancetnik in #1429
• Fix/correct dynamic subscriber registration by @Lancetnik in #1433
• chore: bump version by @Lancetnik in #1435

Full Changelog: 0.5.4...0.5.5