conduktor.io ↗

KIP-834 — Pause / Resume KafkaStreams Topologies

Accepted Kafka 3.3 Streams

Adds `KafkaStreams.pause()` and `KafkaStreams.resume()` methods to suspend and resume all active and standby task processing without stopping the `KafkaStreams` instance. Temporarily halting processing currently requires a full application shutdown and restart, losing in-flight state and triggering unnecessary rebalances.

Details

AuthorJim Hughes
StatusAccepted
Kafka Version3.3
JIRAKAFKA-13873
WikiView on Apache Wiki
Created2022-05-04
Last Modified2022-06-16
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.