Chia-Ping Tsai created KAFKA-21164:
--------------------------------------
Summary: Consider using another anchor to replace lastModified
Key: KAFKA-21164
URL: https://issues.apache.org/jira/browse/KAFKA-21164
Project: Kafka
Issue Type: Improvement
Reporter: Chia-Ping Tsai
Assignee: Chia-Ping Tsai
{code:java}
if (startMs < anchorTimestamp) {
if (remoteLogEnabledAndRemoteCopyEnabled) {
anchorTimestamp = segment.lastModified();
futureTimestampLogger.warn("{} contains future
timestamp(s), using lastModified time {} as the retention anchor", segment,
anchorTimestamp);
} else {
futureTimestampLogger.warn("{} contains future
timestamp(s), making it ineligible to be deleted", segment);
}
} {code}
the critical code is listed above, and related discussion is here
(https://github.com/apache/kafka/pull/22873#discussion_r4100354665)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
