You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Tommy Becker (JIRA)" <ji...@apache.org> on 2017/05/16 14:12:04 UTC
[jira] [Created] (KAFKA-5256) Non-checkpointed state stores should
be deleted before restore
Tommy Becker created KAFKA-5256:
-----------------------------------
Summary: 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)