Skip to content

Pull requests: ag2ai/faststream

New pull request New
22 Open 1,871 Closed
22 Open 1,871 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

feat(redis): support cluster publishing pipelines documentation Improvements or additions to documentation Redis Issues related to `faststream.redis` module and Redis features
#3096 opened Sep 4, 2026 by lxingy3 Contributor Loading…
6 tasks done
1
@lxingy3
3
feat: Allow capturing exception on task execution documentation Improvements or additions to documentation Redis Issues related to `faststream.redis` module and Redis features
#3095 opened Sep 4, 2026 by pbonneaudiabolocom Loading…
10 of 13 tasks
1
@pbonneaudiabolocom
6
fix(nats): bound pull fetches by worker capacity NATS Issues related to `faststream.nats` module and NATS broker features
#3091 opened Sep 2, 2026 by lxingy3 Contributor Loading…
8 tasks done
1
@lxingy3
fix(rabbit): validate cached declarations
#3089 opened Sep 2, 2026 by lxingy3 Contributor Loading…
7 of 9 tasks
@lxingy3
11
feat(redis): use native async cluster pubsub documentation Improvements or additions to documentation Redis Issues related to `faststream.redis` module and Redis features
#3088 opened Sep 1, 2026 by lxingy3 Contributor Loading…
1
@lxingy3
13
feat (#3065): name the context annotation when a handler is hinted with a driver class AioKafka Issues related to `faststream.kafka` module Confluent Issues related to `faststream.confluent` module MQTT Issues related to `faststream.mqtt` module NATS Issues related to `faststream.nats` module and NATS broker features Redis Issues related to `faststream.redis` module and Redis features
#3068 opened Aug 27, 2026 by MannXo Loading…
8 of 9 tasks
1
@MannXo
18
feat(redis): add StreamSub claim_min_idle_time (XREADGROUP CLAIM) documentation Improvements or additions to documentation Redis Issues related to `faststream.redis` module and Redis features
#3049 opened Aug 27, 2026 by kon28289 Contributor Loading…
10 tasks done
1
@kon28289
15
feat: Config values at the App and Broker levels AioKafka Issues related to `faststream.kafka` module Confluent Issues related to `faststream.confluent` module documentation Improvements or additions to documentation MQTT Issues related to `faststream.mqtt` module NATS Issues related to `faststream.nats` module and NATS broker features Redis Issues related to `faststream.redis` module and Redis features
#3030 opened Aug 22, 2026 by Lancetnik Member • Draft
6 of 10 tasks
@Lancetnik
4
fix(fastapi): resolve Optional body params to None for a Kafka tombstone AioKafka Issues related to `faststream.kafka` module Confluent Issues related to `faststream.confluent` module documentation Improvements or additions to documentation
#3028 opened Aug 20, 2026 by aradng Contributor Loading…
7 tasks done
1
@aradng
Suggestion: Use Confluent Kafka's async consumer and producer Confluent Issues related to `faststream.confluent` module enhancement New feature or request
#3017 opened Aug 14, 2026 by ApusBerliozi Collaborator • Draft
11 of 13 tasks
1
@ApusBerliozi
feat: #557 add assert_called_once_with for subscribers and publishers documentation Improvements or additions to documentation
#2996 opened Aug 5, 2026 by IvanKirpichnikov Collaborator Loading…
5 of 13 tasks
1
@IvanKirpichnikov
11
fix(confluent): retry on BufferError so a full queue doesn't cancel the whole batch AioKafka Issues related to `faststream.kafka` module AsyncAPI Issues related to AsyncAPI specification generation bug Something isn't working Confluent Issues related to `faststream.confluent` module dependencies Pull requests that update a dependency file documentation Improvements or additions to documentation github_actions Pull requests that update GitHub Actions code MQTT Issues related to `faststream.mqtt` module NATS Issues related to `faststream.nats` module and NATS broker features Redis Issues related to `faststream.redis` module and Redis features
#2986 opened Aug 4, 2026 by cycsmail Loading…
3 tasks done
1
@cycsmail
6
feat(kafka): explicit TOMBSTONE for publishing and consuming null records AioKafka Issues related to `faststream.kafka` module Confluent Issues related to `faststream.confluent` module documentation Improvements or additions to documentation
#2933 opened Jul 13, 2026 by aradng Contributor Loading…
8 tasks done
@aradng
14
feat sqs broker AioKafka Issues related to `faststream.kafka` module Confluent Issues related to `faststream.confluent` module dependencies Pull requests that update a dependency file documentation Improvements or additions to documentation github_actions Pull requests that update GitHub Actions code MQTT Issues related to `faststream.mqtt` module NATS Issues related to `faststream.nats` module and NATS broker features Redis Issues related to `faststream.redis` module and Redis features
#2913 opened Jun 10, 2026 by vvlrff Contributor • Draft
1
@vvlrff
feat(codec): wire codecs into publishing flow AioKafka Issues related to `faststream.kafka` module Confluent Issues related to `faststream.confluent` module documentation Improvements or additions to documentation MQTT Issues related to `faststream.mqtt` module NATS Issues related to `faststream.nats` module and NATS broker features Redis Issues related to `faststream.redis` module and Redis features
#2902 opened Jun 3, 2026 by ce1ebrimbor Collaborator Loading…
9 tasks done
@ce1ebrimbor
65
fix(cli): surface YAML and AsyncAPI errors from docs serve bug Something isn't working
#2874 opened May 17, 2026 by SarthakB11 Loading…
7 of 9 tasks
@SarthakB11
5
Messages with pattern destination AioKafka Issues related to `faststream.kafka` module Confluent Issues related to `faststream.confluent` module enhancement New feature or request NATS Issues related to `faststream.nats` module and NATS broker features
#2731 opened Jan 7, 2026 by skv0zsneg Loading…
13 tasks
1
@skv0zsneg
7
Feat/asyncapi add reply AioKafka Issues related to `faststream.kafka` module Confluent Issues related to `faststream.confluent` module enhancement New feature or request NATS Issues related to `faststream.nats` module and NATS broker features Redis Issues related to `faststream.redis` module and Redis features
#2635 opened Nov 1, 2025 by stefan-vasilenko Loading…
7 of 10 tasks
1
@stefan-vasilenko
7
Fix: Handle non-UTF-8 headers in Kafka/Confluent message parsing AioKafka Issues related to `faststream.kafka` module Confluent Issues related to `faststream.confluent` module
#2459 opened Aug 15, 2025 by Bazarovinc Contributor • Draft
5 of 9 tasks
2
@draincoder
9
docs: add Prometheus metrics configuration for multi-process mode documentation Improvements or additions to documentation Observability
#2275 opened Jun 9, 2025 by Peopl3s Loading…
9 tasks done
1
@draincoder
10
feat: extented RMQ features enhancement New feature or request RabbitMQ Issues related to `faststream.rabbit` module and RabbitMQ broker features
#1522 opened Jun 12, 2024 by Lancetnik Member • Draft
2 of 13 tasks
2
@Lancetnik
4
draft: WIP SQS integration. broker support Propose a new broker support
#918 opened Nov 9, 2023 by belinux • Draft
3 of 11 tasks
1
@Lancetnik
8
ProTip! Find all pull requests that aren't related to any open issues with -linked:issue.