conduktor.io ↗

KIP-944 — Support async runtimes in consumer

Discarded Consumer

Proposes allowing consumer callbacks (e.g., `onPartitionsRevoked`) to call consumer APIs from a different thread than the poll thread, enabling async runtimes to commit offsets from within rebalance callbacks without deadlocking. The current threading model forbids re-entrant consumer calls, making it impossible to do work in rebalance callbacks with async frameworks.

Details

AuthorErik van Oosten
StatusDiscarded
JIRAKAFKA-14972
WikiView on Apache Wiki
Created2023-06-26
Last Modified2023-08-05
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.