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
| Author | Bruno Cadonna |
| Status | Accepted |
| Kafka Version | 2.8 |
| JIRA | KAFKA-6943 |
| Wiki | View on Apache Wiki |
| Created | 2020-08-24 |
| Last Modified | 2021-01-29 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.