我有一个在Docker容器中运行的KStreams应用程序，它使用持久性键值存储。我的运行环境是Docker 1。RHEL 7上的13.1。
我将state.dir配置为/tmp/kafka-streams（默认值）。
当我使用“docker run”启动这个容器时，我将/tmp/kafka-streams挂载到我的主机上的一个目录，例如/mnt/storage/kafka-streams。
我的application.id是“myapp”。我的输入主题中有288个分区，这意味着我的状态存储/更改日志主题也将有这么多分区。因此，当启动我的Docker容器时，我看到有一个分区编号为0_1，0_2的文件夹。...0_288在/mnt/storage/kafka-streams/myapp/下
当我关闭我的应用程序时，我看不到任何分区目录中的任何.checkpoint文件。
当我重新启动应用程序时，它开始从changelog主题中获取记录，而不是从本地磁盘阅读。我怀疑这是因为在任何分区目录中都没有.checkpoint文件。（注意：我可以在分区目录中看到.lock和rocksdb子目录）
这是我在启动日志中看到的。它似乎是从更新日志主题i引导整个状态存储。e.执行网络I/O而不是从磁盘上阅读：

2022-05-31T12:08:02.791 [mtx-caf-f6900c0a-50ca-43a0-8a4b-95eaad9e5093-StreamThread-122] WARN  o.a.k.s.p.i.ProcessorStateManager - MSG=stream-thread [myapp-f6900c0a-50ca-43a0-8a4b-95eaa
d9e5093-StreamThread-122] task [0_170] State store MyAppRecordStore did not find checkpoint offsets while stores are not empty, since under EOS it has the risk of getting uncommitte
d data in stores we have to treat it as a task corruption error and wipe out the local state of task 0_170 before re-bootstrapping
2022-05-31T12:08:02.791 [myapp-f6900c0a-50ca-43a0-8a4b-95eaad9e5093-StreamThread-122] WARN  o.a.k.s.p.internals.StreamThread - MSG=stream-thread [mtx-caf-f6900c0a-50ca-43a0-8a4b-95eaad
9e5093-StreamThread-122] Detected the states of tasks [0_170] are corrupted. Will close the task as dirty and re-create and bootstrap from scratch.
org.apache.kafka.streams.errors.TaskCorruptedException: Tasks [0_170] are corrupted and hence needs to be re-initialized
        at org.apache.kafka.streams.processor.internals.ProcessorStateManager.initializeStoreOffsetsFromCheckpoint(ProcessorStateManager.java:254)
        at org.apache.kafka.streams.processor.internals.StateManagerUtil.registerStateStores(StateManagerUtil.java:109)
        at org.apache.kafka.streams.processor.internals.StreamTask.initializeIfNeeded(StreamTask.java:216)
        at org.apache.kafka.streams.processor.internals.TaskManager.tryToCompleteRestoration(TaskManager.java:433)
        at org.apache.kafka.streams.processor.internals.StreamThread.initializeAndRestorePhase(StreamThread.java:849)
        at org.apache.kafka.streams.processor.internals.StreamThread.runOnce(StreamThread.java:731)
        at org.apache.kafka.streams.processor.internals.StreamThread.runLoop(StreamThread.java:583)
        at org.apache.kafka.streams.processor.internals.StreamThread.run(StreamThread.java:556)

1.当我关闭我的应用程序时，我应该在/mnt/storage/kafka-streams/myapp/下的每个分区目录中看到一个.checkpoint文件吗？
1.这是一个问题，因为我在docker容器中运行我的KStreams应用程序？如果有权限问题，那么我希望在创建其他文件时看到问题，如。lock或rocksdb文件夹（及其内容）。
1.如果我在我的Windows笔记本电脑上运行这个应用程序作为一个独立的/可运行的Springboot JAR。例如，不在Docker容器中，我可以看到它创建了。检查点文件如预期。