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