conduktor.io ↗

KIP-62 — Allow consumer to send heartbeats from a background thread

Accepted Kafka 1.0 Consumer

Moves consumer group heartbeat sending to a dedicated background `HeartbeatThread`, decoupling heartbeat liveness from the speed of the user's `poll()` processing loop. When message processing in a `poll()` loop takes longer than `session.timeout.ms`, the consumer misses heartbeats, causing a spurious rebalance even if the consumer is healthy and actively processing.

Details

AuthorJason Gustafson
StatusAccepted
Kafka Version1.0
JIRAKAFKA-3888
WikiView on Apache Wiki
Created2016-05-25
Last Modified2017-10-19
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.