Apache NiFi 在集群中分发地图缓存问题

Question

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

• 缓存已写入具有写入缓存的流的节点中（DistributedMapCacheClientService 指向本地主机）
• 客户端只能恢复同一节点中的值。

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

另一个测试是同时从所有节点写入缓存，只对主节点有效。

所以我的问题是：

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

Answer 1

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