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

Reply via email to