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

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

    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

            • Assignee:
              cemo Cemalettin Koç
              Reporter:
              cemo Cemalettin Koç
              Reviewer:
              Matthias J. Sax
            • Votes:
              1 Vote for this issue
              Watchers:
              12 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: