kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kristopher Kane <kkane.l...@gmail.com>
Subject Re: Streams - State store directory created automatically
Date Fri, 05 Jan 2018 21:53:23 GMT
Thanks!

On Fri, Jan 5, 2018 at 3:13 PM, Matthias J. Sax <matthias@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.list@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
> >>
> >
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message