[ https://issues.apache.org/jira/browse/KAFKA-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16015805#comment-16015805 ]
Damian Guy commented on KAFKA-5256: ----------------------------------- >From 0.11.0 onwards we will always have a checkpoint unless exactly once is >turned on. See: https://issues.apache.org/jira/browse/KAFKA-4317 If exactly once is on then we will have to delete the db and restore from scratch. I assume this is being done as part of that work? [~mjsax] [~guozhang] > Non-checkpointed state stores should be deleted before restore > -------------------------------------------------------------- > > Key: KAFKA-5256 > URL: https://issues.apache.org/jira/browse/KAFKA-5256 > Project: Kafka > Issue Type: Bug > Components: streams > Affects Versions: 0.10.2.1 > Reporter: Tommy Becker > > Currently, Kafka Streams will re-use an existing state store even if there is > no checkpoint for it. This seems both inefficient (because duplicate inserts > can be made on restore) and incorrect (records which have been deleted from > the backing topic may still exist in the store). Since the contents of a > store with no checkpoint are unknown, the best way to proceed would be to > delete the store and recreate before restoring. -- This message was sent by Atlassian JIRA (v6.3.15#6346)