如何移除NiFi中DistributedMapCache内存储项？求替代方案

• 使用NiFi的DistributedMapCache（DMC）存储每次新流程执行的数值
• 流程内部分处理器组需等待缓存中的值完成就绪后再执行
• 首次运行后缓存项始终无法彻底移除；将值设为空后仍会被处理器组检测到，无法满足"彻底清除"的需求
• 2023-05-16因未找到解决方案已改用数据库存储，但仍需原问题的技术解法

要彻底删除DMC中的缓存项，需使用正确的处理器操作，而非设置空值：

• 使用DistributedMapCachePut处理器，将Operation参数配置为DELETE，同时指定目标缓存项的Cache Entry Identifier（需与存入时的键完全一致，注意大小写、特殊字符匹配）
• 在流程的收尾阶段添加该处理器，确保每次流程执行完成后自动清理对应缓存键；若需要手动清理，可单独创建一个临时流程，通过指定键执行DELETE操作
• 检查DMC后端存储配置：如果使用Redis等持久化存储后端，需确认缓存键没有被持久化保留（可配合Redis的过期策略，或者在DELETE操作后验证后端存储的键是否已移除）；如果是NiFi内置的内存DMC，重启集群会清空缓存，但不建议用重启作为常规清理方式

如果DistributedMapCache不符合你的需求，可根据场景选择以下内存存储方案：

• LocalMapCache：适用于单节点NiFi场景，基于本地内存实现，无需额外服务。通过LocalMapCachePut的DELETE操作可彻底移除缓存键，无分布式一致性问题，适合不需要跨节点共享的缓存需求
• Flow Variables：若仅需在同一流程实例内的处理器组间共享值，可使用Flow Variables。配合Wait处理器，通过检查变量是否存在来实现"等待值就绪"的逻辑；流程实例结束后变量自动销毁，无需手动清理
• Apache ZooKeeper：适用于跨节点共享且需强一致性协调的场景。使用ZooKeeperPut存入节点，ZooKeeperDelete彻底删除节点，ZooKeeperExists处理器可用于检查节点是否存在（实现等待逻辑），删除后节点完全不存在，不会被检测到

内容的提问来源于stack exchange，提问作者edjm