Cemalettin Koç created KAFKA-6711:
-------------------------------------

             Summary: Checkpoint of InMemoryStore along with GlobalKTable 
                 Key: KAFKA-6711
                 URL: https://issues.apache.org/jira/browse/KAFKA-6711
             Project: Kafka
          Issue Type: Bug
          Components: streams
    Affects Versions: 1.0.1
            Reporter: Cemalettin Koç


We are using an InMemoryStore along with GlobalKTable and I noticed that after 
each restart I am losing all my data. When I debug it, 
`/tmp/kafka-streams/category-client-1/global/.checkpoint` file contains offset 
for my GlobalKTable topic. I had checked GlobalStateManagerImpl implementation 
and noticed that it is not guarded for cases similar to mine. I am fairly new 
to Kafka land and probably there might be another way to fix issue. 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to