conduktor.io ↗

KIP-442 — Return to default max poll interval in Streams

Accepted Kafka 2.3 StreamsConsumer

Restores `max.poll.interval.ms` in Kafka Streams' internal consumer to the standard Kafka default (`300000ms`) instead of the previously overridden `Integer.MAX_VALUE` (effectively infinite). Streams set an infinite poll interval because it did not call `poll()` during state restoration prior to Kafka 1.0; since 1.0 introduced polling during restore, the infinite override is no longer needed and masks real liveness failures.

Details

AuthorJohn Roesler
StatusAccepted
Kafka Version2.3
JIRAKAFKA-6399
WikiView on Apache Wiki
Created2019-03-27
Last Modified2019-04-04
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.