conduktor.io ↗

KIP-224 — Add configuration parameter `retries` to Streams API

Accepted Kafka 1.1 Streams

Adds `retries` and `retry.backoff.ms` configuration parameters to the Kafka Streams API, governing how Streams retries `TimeoutException` errors from global state store bootstrap and `KafkaProducer` timeouts. Without a retry mechanism, a transient broker unavailability during global state bootstrap kills the entire `KafkaStreams` instance with no recovery.

Details

AuthorMatthias J. Sax
StatusAccepted
Kafka Version1.1
JIRAKAFKA-6122
WikiView on Apache Wiki
Created2017-11-09
Last Modified2017-11-20
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.