airtai/faststream

Issues

• Bug: starting the broker breaks in-memory behaviour

  #1479 opened 15 days ago by Klavionik
  2

• Feature: add `Response` class

  #1431 opened 13 days ago by Lancetnik
  5

• Bug: fake consumer doesn't account for routing key

  #1480 opened 13 days ago by Klavionik
  4

• Problems configuring faststream for SASL_SSL security

  #1405 opened a month ago by jorrgme
  1

• Kafka Test Subscriber doesn't match Consumer Group behaviour

  #1412 opened 16 days ago by sinnwise
  2

• Bug:

  #1471 opened 16 days ago by aronicq
  1

• Feature: Provide a way to customize logging in confluent's Consumer and Producer objects

  #1449 opened 17 days ago by andreaimprovised
  1

• Bug: AsyncConfluentProducer / AsyncConfluentConsumer are not that async

  #1363 opened 2 months ago by lecko-cngroup
  0

• Jobs are failing in main branch with pydantic error

  #1466 opened 18 days ago by kumaranvpl
  0

• Bug: Unable to process messages when headers() returns null in batch confluent kafka consumers

  #1459 opened 21 days ago by andreaimprovised
  2

• Bug: TestRabbitBroker's response type should be consistent between mock broker and real RabbitMQ broker

  #1437 opened 25 days ago by maxalbert
  2

• Feature: public API to add middlewares

  #1402 opened 25 days ago by Lancetnik
  0

• Feature: need in receiving headers of certain kafka messages in batch subscription mode

  #1447 opened 25 days ago by yautkin
  1

• Docs: dealing with different schema registries

  #1297 opened 3 months ago by davorrunje
  0

• Feature: Publisher support for async iterator

  #1304 opened 3 months ago by johanjk
  3

• RFE: NATS same subject subscription not registering handlers

  #1308 opened 3 months ago by frct1
  1

• Feature: Allow concurrent RPC calls on rabbit implementation

  #1318 opened 3 months ago by a14n
  5

• Feature: more stronger unique RPC subject names

  #1386 opened 2 months ago by Lancetnik
  0

• Bug: `auto_commit=False` and `retry=True` in confluent-kafka doesn't result in retries

  #1446 opened a month ago by andreaimprovised
  0

• Fix - Check docs for broken links is failing

  #1438 opened a month ago by kumaranvpl
  0

• Feature: make typer optional and move to `faststream[cli]` distribution

  #1430 opened a month ago by Lancetnik
  0

• Feature: add `broker.publisher(filter=...)` option

  #1432 opened a month ago by Lancetnik
  1

• Bug: The Kafka consumer remains blocked indefinitely after commit failures, unable to recover

  #1414 opened a month ago by JohannT9527
  0

• Bug: TestRabbitBroker does not throw error when `rpc` and `reply_to` are both provided

  #1415 opened a month ago by maxalbert
  0

• Bug: FastStream global context set is not access in pytest

  #1403 opened a month ago by kusime
  1

• ActiveMQ support

  #1373 opened 2 months ago by v2boardbot
  3

• Bug: Router Prefix breaks Path() from properly retrieving the subject token defined.

  #1393 opened 2 months ago by aKardasz
  0

• Bug: unbound error on base middleware handler

  #1379 opened 2 months ago by chrisgoddard
  4

• Bug: Publisher Direct Usage

  #1384 opened 2 months ago by taras0024
  4

• Bug:<RedisBroker> failed to connect to Redis instance by <url>

  #1376 opened 2 months ago by farzbood
  3

• Bug: Deserialization of list[Model[T]] not working in v5

  #1375 opened 2 months ago by chrisgoddard
  3

• Feature: use subscribe in KafkaBroker to create handlers with explicit options propagation

  #1319 opened 2 months ago by Lancetnik
  0

• Create docs according to design (image)

  #1350 opened 2 months ago by davorrunje
  0

• Implement explicit methods annotations in Kafka and confluent brokers (Refer RabbitBroker)

  #1311 opened 2 months ago by davorrunje
  1

• Bug: After Closing a RabbitBroker(), others RabbitBroker() can't publish anymore

  #1346 opened 2 months ago by gcadiou
  1

• Bug: Reload option sometimes triggers TypeError: not all arguments converted during string formatting

  #1364 opened 2 months ago by pySilver
  1

• Add dev containers (for different brokers and for all brokers)

  #1351 opened 2 months ago by davorrunje
  0

• Feature: don't pin the nats client upper version

  #1303 opened 2 months ago by strangemonad
  1

• refactor: move pydantic.BaseModel usages to dataclasses

  #1287 opened 2 months ago by Lancetnik
  0

• Feature: Deferred initialization of topic names

  #1343 opened 2 months ago by johanjk
  1

• Feature: Allow passing kwargs to underlying broker library

  #1337 opened 2 months ago by surculus12
  2

• Bug: rpc calls cannot be executed asynchronously

  #1339 opened 2 months ago by v2boardbot
  1

• Bug: Warning about deprecated features when using latest RabbitMQ

  #1325 opened 3 months ago by gaby
  2

• Feature: broker syncify wrapper

  #1289 opened 3 months ago by allran
  4

• Bug: FastAPI integration failed to start because of non-existed logger

  #1305 opened 3 months ago by DmitriyKalekin
  2

• Bug: `AttributeError: 'list' object has no attribute 'items' with "Discriminated Unions"

  #1263 opened 3 months ago by Kilo59
  2

• Bug: BufferError in confluent kafka broker

  #1276 opened 3 months ago by kumaranvpl
  0

• Feature: allow to use XXXDsn from Pydantic while specyfing the URL

  #1275 opened 3 months ago by ntoskrn
  1

• Pytest dependency snuck through.

  #1274 opened 3 months ago by jmayo-benchsci
  1

• Bug: Depends error with incoming message

  #1271 opened 4 months ago by WATUNeed
  1