conduktor.io ↗

KIP-663 — API to Start and Shut Down Stream Threads

Accepted Kafka 2.8 Streams

Adds `KafkaStreams.addStreamThread()` and `KafkaStreams.removeStreamThread()` methods to allow dynamic scaling of stream thread count at runtime without restarting the Streams client. Currently, if a stream thread dies due to an uncaught exception, the only recovery option is to restart the entire `KafkaStreams` client, causing unnecessary downtime.

Details

AuthorBruno Cadonna
StatusAccepted
Kafka Version2.8
JIRAKAFKA-6943
WikiView on Apache Wiki
Created2020-08-24
Last Modified2021-01-29
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.