WARN [2018-08-24 16:23:48,209] org.apache.kafka.streams.processor.internals.ProcessorStateManager: task [0_22] Failed to write offset checkpoint file to /data/kafka-streams//0_22/.checkpoint: {} ! java.nio.file.NoSuchFileException: /data/kafka-streams//0_22/.checkpoint.tmp ! at sun.nio.fs.UnixException.translateToIOException(UnixException.java:86) ! at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102) ! at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:107) ! at sun.nio.fs.UnixCopyFile.move(UnixCopyFile.java:409) ! at sun.nio.fs.UnixFileSystemProvider.move(UnixFileSystemProvider.java:262) ! at java.nio.file.Files.move(Files.java:1395) ! at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:786) ! at org.apache.kafka.streams.state.internals.OffsetCheckpoint.write(OffsetCheckpoint.java:92) ! at org.apache.kafka.streams.processor.internals.ProcessorStateManager.checkpoint(ProcessorStateManager.java:315) ! at org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:383) ! at org.apache.kafka.streams.processor.internals.StreamTask.commit(StreamTask.java:368) ! at org.apache.kafka.streams.processor.internals.AssignedTasks$1.apply(AssignedTasks.java:67) ! at org.apache.kafka.streams.processor.internals.AssignedTasks.applyToRunningTasks(AssignedTasks.java:362) ! at org.apache.kafka.streams.processor.internals.AssignedTasks.commit(AssignedTasks.java:352) ! at org.apache.kafka.streams.processor.internals.TaskManager.commitAll(TaskManager.java:401) ! at org.apache.kafka.streams.processor.internals.StreamThread.maybeCommit(StreamThread.java:1035) ! at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:845) ! at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:767) ! at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:736) ! Suppressed: java.nio.file.NoSuchFileException: /data/kafka-streams//0_22/.checkpoint.tmp -> /data/kafka-streams//0_22/.checkpoint ! at sun.nio.fs.UnixException.translateToIOException(UnixException.java:86) ! at sun.nio.fs.UnixException.rethrowAsIOException(UnixException.java:102) ! at sun.nio.fs.UnixCopyFile.move(UnixCopyFile.java:396) ! at sun.nio.fs.UnixFileSystemProvider.move(UnixFileSystemProvider.java:262) ! at java.nio.file.Files.move(Files.java:1395) ! at org.apache.kafka.common.utils.Utils.atomicMoveWithFallback(Utils.java:783) ! ... 12 common frames omitted