Thanks!
On Fri, Jan 5, 2018 at 3:13 PM, Matthias J. Sax <matth...@confluent.io>
wrote:
> We always create task directories -- this helps to cleanly hand over
> tasks and detect reassignment issues (via the .lock)
>
> The checkpoint file will be empty if you don't use any state.
>
> -Matthias
>
> On 1/4/18 7:15 PM, Ted Yu wrote:
> > 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
> >>
> >
>
>
