akka-persistent-actor-example:羊驼，卡夫卡，React流，演员模型，阿卡

工作任务 特征： 列出目录中的所有文件并将其名称发送到kafka 跟踪目录中每个新创建的文件并发送到kafka 特定的：处理应用程序重新启动，将已处理文件的状态保存在本地节点上（与kafka分离） 解决方案 为了列出目录中的所有文件并跟踪事件，我使用了 清单 final Source<PathAndProcessed> listDirSource = Directory.ls(fs.getPath(imgDir)) .mapAsync(1, (Path e) -> { return PatternsCS.ask( persistentActor, new IsFileProcessed(e.toString()), Duration.ofSeconds(4).toMillis())