All pull requests

Pull requests

• fix(redis): stop ListBatchPublisher from passing as a ListPublisher

  Redis
  #3242·vyhuholl opened Sep 26, 2026Contributor·

  ·

• fix(kafka): log partition assignment when a custom rebalance listener…

  AioKafka
  #3241·vyhuholl opened Sep 26, 2026Contributor·

  ·

• fix: strip credentials from AsyncAPI specification URLs

  NATSRedis
  #3239·Vitaly312 opened Sep 25, 2026Contributor·

  ·

• Pass api_version and client_rack only to an aiokafka that takes them

  AioKafka
  #3237·vyhuholl opened Sep 24, 2026Contributor·

  ·

• Handover the message for the middleware for the on_receive method

  Observability
  #3235·ApusBerliozi opened Sep 24, 2026Collaborator·

  ·
  1

  2

• Require a destination in subscriber() and publisher() overloads

  Redis
  #3234·vyhuholl opened Sep 24, 2026Contributor·

  ·
  2

• Feature: Implementation of the AsyncContextManager interface for Application #3228

  documentation
  #3233·ProstoKiReal opened Sep 24, 2026·

  ·
  1

  3

• perf!: slot the public objects user code constructs, receives or holds

  1.0.0AioKafkaAsyncAPIConfluentdependenciesdocumentationMQTTNATSObservabilityRedis
  #3230·Lancetnik opened Sep 23, 2026Member·

  ·

• fix(mqtt): do not send UNSUBSCRIBE on broker shutdown

  documentationMQTT
  #3224·duetooyou opened Sep 23, 2026·

  ·
  1

• feat(kafka): add Topic schema and hang declare on TopicPartition

  AioKafkaAsyncAPIConfluentdocumentation
  #3223·ce1ebrimbor opened Sep 22, 2026Collaborator·

  ·
  1

  1

  

• docs: codify the recurring part of review as skills

  documentationgithub_actionsRedis
  #3148·Lancetnik opened Sep 18, 2026Member·

  ·

• feat: #2806 Add public API

  1.0.0AioKafkaAsyncAPIConfluentMQTTNATSObservabilityRedis
  #3141·IvanKirpichnikov opened Sep 16, 2026Collaborator·

  ·
  

• feat: #3044 Add support pipe and remove types-redis

  1.0.0dependenciesdocumentationRedis
  #3139·IvanKirpichnikov opened Sep 16, 2026Collaborator·2/2·

  ·
  6

  

• 1.0.0

  1.0.0AioKafkaAsyncAPIConfluentdependenciesgithub_actionsMQTTNATSObservabilityRedis
  #3125·Lancetnik opened Sep 12, 2026Member·

  ·

• feat(testing): RabbitMQ, NATS, Redis and MQTT handlers and publishers assert on their own fields

  AioKafkaConfluentdocumentationMQTTNATSRedis
  #3120·Lancetnik opened Sep 12, 2026Member·4/4·

  ·
  

• feat(testing): Kafka handlers and publishers assert on key and partition

  AioKafkaConfluentdocumentation
  #3113·Lancetnik opened Sep 9, 2026Member·3/4·

  ·
  6

  

• refactor(rabbit): read queue, exchange and routing key through one layer

  AsyncAPI
  #3109·Lancetnik opened Sep 8, 2026Member·

  ·

• Add new benchmarks

  1.0.0Coredependenciesenhancement
  #3107·ApusBerliozi opened Sep 8, 2026Collaborator·

  ·
  1

  2

  

• fix(nats): clean up failed JetStream request subscriptions

  NATS
  #3097·Kuang-xianxin opened Sep 7, 2026·

  ·
  7

• feat: Allow capturing exception on task execution

  documentationRedis
  #3095·pbonneaudiabolocom opened Sep 4, 2026·

  ·
  1

  11

  

• fix(nats): bound pull fetches by worker capacity

  NATS
  #3091·lxingy3 opened Sep 2, 2026Contributor·

  ·
  1

  

• fix(rabbit): validate cached declarations

  #3089·lxingy3 opened Sep 2, 2026Contributor·

  ·
  16

  

• feat (#3065): name the context annotation when a handler is hinted with a driver class

  AioKafkaConfluentMQTTNATSRedis
  #3068·MannXo opened Aug 27, 2026·

  ·
  1

  27

  

• feat: Config values at the App and Broker levels

  AioKafkaConfluentdocumentationMQTTNATSRedis
  #3030·Lancetnik opened Aug 22, 2026Member·

  ·
  4

  

• fix(fastapi): resolve Optional body params to None for a Kafka tombstone

  AioKafkaConfluentdocumentation
  #3028·aradng opened Aug 20, 2026Contributor·

  ·
  1

  2