All pull requests

Pull requests

• Don't block rejoin for a consumer with no partitions

  #1189·vmirz opened Sep 19, 2026·

  ·
  1

  3

• Map and handle FENCED_INSTANCE_ID (error 82)

  #1188·vmirz opened Sep 19, 2026·

  ·
  1

  7

• fix(coordinator): invoke on_generation_assignment on join complete (#…

  #1185·utku0dogan opened Sep 12, 2026·

  ·
  1

  3

• Fix zig-zag encoding in VarInt32 and VarInt64

  #1178·dylanpulver opened Sep 2, 2026·

  ·
  2

• Don't send more than one JoinGroup request when more than one Assignors are specified

  #1168·ilolis opened Jun 13, 2026·

  ·

• fix: add full jitter to Fetcher retry backoff (thundering herd on leader election)

  #1167·KaustubhUp025 opened Jun 4, 2026·

  ·
  1

• feat: use zstd from stdlib on python >= 3.14

  #1161·sk- opened May 3, 2026·

  ·
  1

  1

• Bump pytest from 9.0.2 to 9.0.3 in the pip group across 1 directory

  dependenciespython
  #1157·dependabot[bot] opened Apr 14, 2026Bot·

  ·
  1

• perf: optimize MessageBatch.wait_drain() to avoid asyncio.wait overhead

  #1144·gloryfromca opened Dec 29, 2025·

  ·
  2

• fix: make AIOKafkaProducer.start() idempotent to prevent busy loop

  #1143·gloryfromca opened Dec 29, 2025·

  ·

• Avoid unclosed consumer and producer warnings when using AsyncContextManager interface

  #1131·calgray opened Oct 24, 2025·

  ·
  1

• Make AIOKafkaAdminClient an asynchronous context manager

  #1129·PeterJCLaw opened Oct 21, 2025·

  ·
  1

• Include "start" in the try/finally in docs

  #1128·vmaurin opened Oct 2, 2025Contributor·

  ·
  1

  1

• Use fastest compression level

  #1121·dolfinus opened Aug 15, 2025·

  ·
  1

  1

• feat(fetch): add full Fetch v10 support

  #1111·mesteruh opened May 28, 2025·

  ·

• 712.bugfix: wait when metadata update

  #1108·khab-el opened May 13, 2025·

  ·
  1

• Add support for rack id in the consumer

  #1107·vbhavsar opened May 12, 2025·

  ·
  1

  2

• KIP-368: Allow SASL Connections to Periodically Re-Authenticate

  #1105·kprzybyla opened May 6, 2025·

  ·
  2

  14

• Assert if the consumer has started before performing an operation

  #1104·kPsarakis opened Apr 17, 2025·

  ·
  1

• Add concurrent consumption example to docs

  #1092·Arseniy-Popov opened Feb 16, 2025·

  ·

• Add round robin partitioner

  #1088·Arseniy-Popov opened Jan 27, 2025·

  ·

• Add stub typing for clients

  #1075·jackgene opened Nov 15, 2024Contributor·

  ·
  1

  10

• Added type annotation to public classes.

  #1074·jackgene opened Nov 15, 2024Contributor·

  ·
  1

  4

• fix: check writer is closing in AIOKafkaConnection.send

  #1044·dimastbk opened Aug 19, 2024Contributor·

  ·
  1

  6

• Add type hints to message_accumulator

  #1026·antonagestam opened Jul 2, 2024·

  ·