Looks like the .checkpoint file was generated from this code in ProcessorStateManager :
// write the checkpoint file before closing, to indicate clean shutdown try { if (checkpoint == null) { checkpoint = new OffsetCheckpoint(new File(baseDir, CHECKPOINT_FILE_NAME)); FYI On Thu, Jan 4, 2018 at 11:48 AM, Kristopher Kane <kkane.l...@gmail.com> wrote: > I just noticed /tmp/kafka-streams/<app id>/0_[0,1]/{.checkpoint,.lock] > (there are two partitions on the incoming topic) being automatically > created during an integration test. My Streams app doesn't use a state > store and only contains mapValues and a .to termination operation. > > Anyone know what this is for? > > Thanks, > > Kris >