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
| Author | Richard Yu |
| Status | Discussion |
| JIRA | KAFKA-7480 |
| Wiki | View on Apache Wiki |
| Created | 2018-12-16 |
| Last Modified | 2020-10-26 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.