Bill Bejeck created KAFKA-20940:
-----------------------------------
Summary: Windowed changelog restore optimization is skipped
whenever a checkpointed offset exists
Key: KAFKA-20940
URL: https://issues.apache.org/jira/browse/KAFKA-20940
Project: Kafka
Issue Type: Improvement
Components: streams
Affects Versions: 4.3.0, 4.4.0
Reporter: Bill Bejeck
Assignee: Alan Lau
Fix For: 4.3.2, 4.5.0, 4.4.1
KAFKA-13499 added an optimization to StoreChangelogReader that avoids restoring
already-expired records for windowed/session stores by seeking to
latestChangelogTimestamp - retentionPeriod instead of seeking to the beginning.
However, in StoreChangelogReader#prepareChangelogs the optimization only
executes when no start offset is available. When a start offset is found, the
reader unconditionally does restoreConsumer.seek(partition, currentOffset + 1)
and restores every record from that offset forward.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
