conduktor.io ↗

KIP-945 — Update threading model for Consumer

Discussion Kafka 3.8 Consumer

Refactors the `KafkaConsumer` threading model by moving heartbeating and coordinator communication to a dedicated background thread while keeping application callbacks on the calling thread. The existing implementation mixes application-thread and background-thread execution in ways that make the code fragile, hard to reason about, and prone to subtle concurrency bugs.

Details

AuthorKirk True
StatusDiscussion
Kafka Version3.8
JIRAKAFKA-14246
WikiView on Apache Wiki
Created2023-06-29
Last Modified2023-07-12
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.