Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-6711

GlobalStateManagerImpl should not write offsets of in-memory stores in checkpoint file

    XMLWordPrintableJSON

Details

    Description

      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. 

      Attachments

        Activity

          People

            cemo Cemalettin Koç
            cemo Cemalettin Koç
            Matthias J. Sax Matthias J. Sax
            Votes:
            1 Vote for this issue
            Watchers:
            10 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: