kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax" <matth...@confluent.io>
Subject Re: Streams - State store directory created automatically
Date Fri, 05 Jan 2018 20:13:35 GMT
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
View raw message