conduktor.io ↗

KIP-406 — GlobalStreamThread should honor custom offset policy.

Discussion Streams

Makes `GlobalStreamThread` automatically handle `InvalidOffsetException` by resetting offsets according to the application's `auto.offset.reset` policy and rebuilding the global state store, instead of propagating the exception to the user. Previously, receiving an `InvalidOffsetException` from global store topics required a manual application restart, whereas stream threads already handle this automatically.

Details

AuthorRichard Yu
StatusDiscussion
JIRAKAFKA-7480
WikiView on Apache Wiki
Created2018-12-16
Last Modified2020-10-26
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.