apache-nifi - 如何为 NiFi 设置分布式 map 缓存？

Question

我是 NiFi 的新手，只是在玩处理器。

我试图在我的测试中加入 Wait 和 Notify 处理器，但我必须设置一个分布式 map 缓存(服务器 和 0x251819421134111)。

NiFi 文档假设了我没有的理解水平。

我已经在我的计算机 (macOS) 上安装了 memcached 并验证它在端口 11211(默认)上运行。我在 NiFi 的 DistributedMapCacheClientService 下创建了 DistributedMapCacheServer 和 CONTROLLER SERVICES ，但我收到了 java.net.SocketTimeoutException 和其他错误。

是否有关于整个主题的好教程？有人可以建议如何前进吗？

Answer 1

DistributedMapCacheClientService 和 DistributedMapCacheServer 不需要额外的软件。

要创建这些服务，请右键单击 Canvas ，选择 Configure，然后选择 Controller Services 选项卡。然后，您可以通过单击右侧的 + 按钮并按名称搜索来添加新服务。

使用默认参数(端口 4557)创建 DistributedMapCacheServer 并启用它。这将启动内置缓存服务器。

使用主机名 DistributedMapCacheClientService 和其他默认参数创建 localhost 并启用它

创建一个简单的流 GenerateFlowFile 在参数中设置 run schedule 和非零字节大小。
将其连接到 PutDistributedMapCache 将 Entry Identifier 设置为 Key01 并选择您的 DistributedMapCacheClientService

尝试运行它。如果其他软件未使用端口 4557，则放置缓存应该可以工作。