如何为NiFi设置分布式映射缓存？

Question

我是NiFi的全新品牌，只是玩弄处理器。

我试图将Wait和Notify处理器在我的测试，但我必须建立一个分布式地图缓存（服务器和客户端？）。

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

我已经在我的电脑（macOS）上安装了memcached，并确认它在端口11211上运行（默认）。我在N1Fi的CONTROLLER SERVICES下创建了DistributedMapCacheClientService和DistributedMapCacheServer，但我得到java.net.SocketTimeoutException &其他错误。

在整个主题上有很好的教程吗？有人可以建议如何前进？

Answer 1

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

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

2. 创建DistributedMapCacheClientService与主机名localhost和其他默认参数并使其

3. 创建一个简单的流GenerateFlowFile在参数中设定的run schedule，而不是零字节大小。 它连接到PutDistributedMapCache设置Entry Identifier为Key01，并选择您DistributedMapCacheClientService

尝试运行它。如果端口4557未被其他软件使用，put cache应该可以工作。