如何为NiFi设置分布式地图缓存？

Question

我是NiFi的新手,只是玩处理器.

我正在尝试在我的测试中加入Wait和Notify处理器,但我必须设置分布式地图缓存(服务器和客户端？).

NiFi文档假设我不具备的理解水平.

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

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

Answer 1

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

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

2. Controller Services使用主机名+和其他默认参数创建并启用它

3. 创建一个简单的流DistributedMapCacheServer设置DistributedMapCacheClientService参数而不是零字节大小.连接它以localhost设置GenerateFlowFile为run schedule 并选择你的PutDistributedMapCache

尝试运行它.如果端口4557没有被其他软件使用,则put缓存应该有效.