conduktor.io ↗

KIP-216 — IQ should throw different exceptions for different errors

Accepted Kafka 3.0 Streams

Introduces typed subclasses of `InvalidStateStoreException` for Interactive Queries—`StreamsNotRunningException`, `InvalidStateStorePartitionException`, and `UnknownStateStoreException`—to distinguish the root cause of a failed state store lookup. The single `InvalidStateStoreException` thrown for all IQ errors forces callers to parse exception messages or use catch-all retry logic regardless of whether the error is transient (rebalance) or permanent (wrong store name).

Details

Authorvitojeng
StatusAccepted
Kafka Version3.0
JIRAKAFKA-5876
WikiView on Apache Wiki
Created2017-10-27
Last Modified2020-02-02
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.