All pull requests

Pull requests

• fix(confluent): store offsets explicitly on manual ack (#3312)

  Confluent
  #3317·agustin18 opened Oct 31, 2026Contributor·6 of 7 tasks·

  ·
  1

  1

• feat: accept Redis and NATS destination objects in broker methods

  documentationNATSRedis
  #3311·DMINQ opened Oct 30, 2026·2 tasks done·

  ·
  1

• refactor(subscriber): replace Tasks/Concurrent mixins with composable dispatchers across all brokers

  AioKafkaConfluentdependenciesMQTTNATSRedis
  #3309·Vitaly312 opened Oct 29, 2026Contributor·6 tasks done·

  ·

• fix(rabbit): cancel the consumer before waiting for in-flight handlers on stop

  #3298·benedikt-bartscher opened Oct 25, 2026Contributor·5 tasks done·

  ·
  4

• feat: emit AsyncAPI channel parameters for address templates

  AioKafkaAsyncAPIConfluentdocumentation
  #3290·dajiaohuang opened Oct 22, 2026·

  ·
  1

  10

• refactor: type the subscriber parsing flow end to end (core, redis)

  AioKafkaAsyncAPIMQTTNATSRedis
  #3279·Vitaly312 opened Oct 21, 2026Contributor·6 tasks done·

  ·

• feat: add support python 3.15

  github_actions
  #3273·IvanKirpichnikov opened Oct 17, 2026Collaborator·13 tasks·

  ·

• fix(confluent): ignore late delivery callbacks

  Confluent
  #3268·sean0407 opened Oct 12, 2026·3 tasks done·

  ·
  1

  2

• 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·8 of 13 tasks·

  ·
  

• 1.0.0

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

  ·

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

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

  ·
  

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

  AsyncAPI
  #3109·Lancetnik opened Sep 8, 2026Member·4 tasks done·

  ·

• Add new benchmarks

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

  ·
  1

  2

  

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

  NATS
  #3091·lxingy3 opened Sep 2, 2026Contributor·8 tasks done·

  ·
  1

  

• fix(rabbit): validate cached declarations

  #3089·lxingy3 opened Sep 2, 2026Contributor·

  ·
  20

  

• feat: Config values at the App and Broker levels

  AioKafkaConfluentdocumentationMQTTNATSRedis
  #3030·Lancetnik opened Aug 22, 2026Member·6 of 10 tasks·

  ·
  4

  

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

  AioKafkaConfluentdocumentation
  #3028·aradng opened Aug 20, 2026Contributor·7 tasks done·

  ·
  1

  3

  

• Suggestion: Use Confluent Kafka's async consumer and producer

  Confluentenhancement
  #3017·ApusBerliozi opened Aug 14, 2026Collaborator·11 of 13 tasks·

  ·
  1

  

• fix(confluent): ignore late delivery reports, opt-in retry_on_buffer_error for batches

  AioKafkaAsyncAPIbugConfluentdependenciesdocumentationgithub_actionsMQTTNATSRedis
  #2986·cycsmail opened Aug 4, 2026·11 tasks done·

  ·
  1

  7

  

• feat(kafka): explicit TOMBSTONE for publishing and consuming null records

  AioKafkaConfluentdocumentation
  #2933·aradng opened Jul 13, 2026Contributor·8 tasks done·

  ·
  16

  

• feat sqs broker

  AioKafkaConfluentdependenciesdocumentationgithub_actionsMQTTNATSRedis
  #2913·vvlrff opened Jun 10, 2026Contributor·

  ·
  1

  

• feat(codec): wire codecs into publishing flow

  AioKafkaConfluentdocumentationMQTTNATSRedis
  #2902·ce1ebrimbor opened Jun 3, 2026Collaborator·9 tasks done·

  ·
  65

  

• Messages with pattern destination

  AioKafkaConfluentenhancementNATS
  #2731·skv0zsneg opened Jan 7, 2026·13 tasks·

  ·
  1

  7

  

• Feat/asyncapi add reply

  AioKafkaConfluentenhancementNATSRedis
  #2635·stefan-vasilenko opened Nov 1, 2025·7 of 10 tasks·

  ·
  1

  7