conduktor.io ↗

KIP-662 — Throw Exception when Source Topics of a Streams App are Deleted

Accepted Kafka 2.7 Streams

Changes Kafka Streams behavior when source topics are deleted at runtime: instead of silently shutting down all stream threads, the application now throws a `MissingSourceTopicException` via the streams uncaught exception handler so the application can handle or surface the error explicitly. The silent shutdown with an ERROR log is insufficient for production systems that need explicit notification and recovery logic when source topics disappear.

Details

AuthorBruno Cadonna
StatusAccepted
Kafka Version2.7
JIRAKAFKA-10355
WikiView on Apache Wiki
Created2020-08-21
Last Modified2020-08-31
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.