Search results

Fetcher advances the consumed position past a record it never returned (RecordTooLargeError) — silent record loss under async iteration

Status: Open.

#1173 In aio-libs/aiokafka;

· christian-schlichtherle opened on Jul 26, 2026

Spurious NotEnoughReplicasError on exactly-once read-process-write against Kafka 4.x with Eligible Leader Replicas (KIP-966) enabled

Status: Open.

#1172 In aio-libs/aiokafka;

· christian-schlichtherle opened on Jul 19, 2026

Add a lightweight metrics collector protocol for the producer

Status: Open.

#1166 In aio-libs/aiokafka;

· GlebShipilov opened on Jun 3, 2026

PR #1164: fetch backoff for NotLeaderForPartitionError uses fixed delay — thundering herd risk

Status: Open.

#1165 In aio-libs/aiokafka;

· KaustubhUp025 opened on May 31, 2026

Missing retry backoff in Fetcher for NotLeaderForPartitionError causes tight fetch loop during broker restarts

Status: Open.

#1155 In aio-libs/aiokafka;

· vanchaxy opened on Mar 2, 2026

Consider using zstd from stdlib for Python >= 3.14

enhancement

Status: Open.

#1146 In aio-libs/aiokafka;

· sk- opened on Jan 9, 2026

Transactions remain stuck on broker change

Status: Open.

#1145 In aio-libs/aiokafka;

· nicolaferraro opened on Jan 8, 2026

[QUESTION] NodeNotReadyError: Attempt to send a request to node which is not ready (node id 4)

question

Status: Open.

#1133 In aio-libs/aiokafka;

· saper opened on Nov 10, 2025

Unclosed consumer and producer warnings when using AsyncContextManager interface

Status: Open.

#1130 In aio-libs/aiokafka;

· calgray opened on Oct 24, 2025

‎AIOKafkaProducer.send‎ shuffles partitions when running in PyPy environments

Status: Open.

#1127 In aio-libs/aiokafka;

· gh-andre opened on Sep 26, 2025

Support for CooperativeStickyAssignor

enhancement

Status: Open.

#1126 In aio-libs/aiokafka;

· jorgemo-fever opened on Sep 26, 2025

test_read_write_serde_v2[zstd] fails with cramjam 2.11.0

Status: Open.

#1124 In aio-libs/aiokafka;

· kovalev0 opened on Sep 3, 2025