conduktor.io ↗

KIP-696 — Update Streams FSM to clarify ERROR state meaning

Accepted Kafka 2.8 Streams

Adds a `PENDING_ERROR` transient state to the `KafkaStreams` FSM with transitions `RUNNING/REBALANCING → PENDING_ERROR → ERROR`, and removes the `ERROR → PENDING_SHUTDOWN` transition to make `ERROR` a true terminal state. KIP-663 removed the automatic transition to `ERROR` when all threads die, making the original `ERROR` state definition (no threads running) ambiguous and logically inconsistent.

Details

AuthorWalker Carlson
StatusAccepted
Kafka Version2.8
JIRAKAFKA-10555
WikiView on Apache Wiki
Created2020-12-02
Last Modified2021-01-26
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.