caching - Apache NiFi 集群中的分布式 map 缓存问题

Question

我将在单节点 NiFi 上工作的流程移至 3 节点 NiFi 集群，突然，使用 DistributedMapCache 的等待处理器无法按预期工作，这意味着无法恢复来自缓存的值。为了确保该值存在于缓存中，我将缓存配置为使用持久目录，因此我能够检查缓存的内容，经过一些测试后意识到:

• 缓存写入到具有写入缓存的流程的节点中(DistributedMapCacheClientService 指向 localhost)
• 客户端只能恢复同一节点中的值。

另一个测试是强制在主节点中执行流，在这种情况下，一切都按预期进行。

另一个测试是同时从所有节点写入缓存，仅适用于主节点。

所以我的问题是:

• DistributedMapCache 真的分布在整个集群中吗？
• 我可能遗漏了某些要点或配置错误吗？

Answer 1

您不应该在 DistributedMapCacheClientService 中使用 localhost，只需使用其中一个节点的主机名，然后所有客户端都将指向同一服务器。