alanlau28 opened a new pull request, #23087: URL: https://github.com/apache/kafka/pull/23087
Jira: https://issues.apache.org/jira/browse/KAFKA-20876 4.3 restores a checkpointless windowed store from log-start unconditionally. Log-start is the offset a delete-retention changelog is being trimmed from, so the restore has zero margin: it survives only by out-reading the writer, and raises `OffsetOutOfRangeException` otherwise, marking the task corrupted. This backports KAFKA-13499 to 4.3 with https://github.com/apache/kafka/pull/23086. Also includes the `PlainToHeadersWindowStoreAdapter` fix (https://github.com/apache/kafka/pull/23037), which trunk carries in a separate PR but which 4.3 needs here: the adapter holds its delegate in a private field rather than as a `WrappedStateStore`, so `extractRetentionPeriod`'s unwrap walk terminates on it and resolves `-1`, silently skipping the optimisation for **every stream-stream join store**. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
