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
| Author | Kirk True |
| Status | Discussion |
| Kafka Version | 3.8 |
| JIRA | KAFKA-14246 |
| Wiki | View on Apache Wiki |
| Created | 2023-06-29 |
| Last Modified | 2023-07-12 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.