All issues

Consumer holding no partitions can never rejoin after max_poll_interval_ms

#1187

· vmirz opened

on Sep 19, 2026

FENCED_INSTANCE_ID (error 82) is unmapped and raised as an untyped KafkaError

#1186

· vmirz opened

on Sep 19, 2026

Add lightweight consumer metrics collector

#1177

· GlebShipilov opened

on Aug 31, 2026

StickyPartitionAssignor.on_generation_assignment is defined but never invoked from GroupCoordinator

#1176

· cloudnativeninja-GV opened

on Aug 18, 2026

StickyPartitionAssignor is unsafe when multiple AIOKafkaConsumer instances share a Python process (class-level state clobber)

#1175

· cloudnativeninja-GV opened

on Aug 18, 2026

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

#1173

· 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

#1172

· christian-schlichtherle opened

on Jul 19, 2026

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

#1165

· KaustubhUp025 opened

on May 31, 2026

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

#1155

· vanchaxy opened

on Mar 2, 2026

Consider using zstd from stdlib for Python >= 3.14

#1146

· sk- opened

on Jan 9, 2026

Transactions remain stuck on broker change

#1145

· nicolaferraro opened

on Jan 8, 2026

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

#1133

· saper opened

on Nov 10, 2025