[jira] [Comment Edited] (KAFKA-14241) Implement the snapshot cleanup policy

["Jose Armando Garcia Sancio (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-14241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17606669#comment-17606669 ] 

Jose Armando Garcia Sancio edited comment on KAFKA-14241 at 9/19/22 4:32 PM:
-----------------------------------------------------------------------------

Yes and that topic is internal at the moment. So at high-level we need to have a more complicated validation logic that is able to distinguish if the affected topic is a KRaft topic vs an ISR topic.


was (Author: jagsancio):
Yes and those topics are internal at the moment. So at high-level we need to have a more complicated validation logic that is able to distinguish if the affected topic is a KRaft topic vs an ISR topic.

> Implement the snapshot cleanup policy
> -------------------------------------
>
>                 Key: KAFKA-14241
>                 URL: https://issues.apache.org/jira/browse/KAFKA-14241
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: kraft
>            Reporter: Jose Armando Garcia Sancio
>            Assignee: Jose Armando Garcia Sancio
>            Priority: Major
>             Fix For: 3.4.0
>
>
> It looks like delete policy needs to be set to either delete or compact:
> {code:java}
>         .define(CleanupPolicyProp, LIST, Defaults.CleanupPolicy, ValidList.in(LogConfig.Compact, LogConfig.Delete), MEDIUM, CompactDoc,
>           KafkaConfig.LogCleanupPolicyProp)
> {code}
> Neither is correct for KRaft topics. KIP-630 talks about adding a third policy called snapshot:
> {code:java}
> The __cluster_metadata topic will have snapshot as the cleanup.policy. {code}
> [https://cwiki.apache.org/confluence/display/KAFKA/KIP-630%3A+Kafka+Raft+Snapshot#KIP630:KafkaRaftSnapshot-ProposedChanges]



--
This message was sent by Atlassian Jira
(v8.20.10#820010)