How does one setup a Distributed Map Cache for NiFi?

@Darshan Yey it will work beacause in the documentation of DistributedMapCacheClientService says that it :

Provides the ability to communicate with a DistributedMapCacheServer. This can be used in order to share a Map between nodes in a NiFi cluster


the DistributedMapCacheClientService and DistributedMapCacheServer does not require additional software.

To create these services, right-click on the canvas, select Configure and then select the Controller Services tab. You can then add new services by clicking the + button on the right and searching by name.

  1. create DistributedMapCacheServer with default parameters (port 4557) and enable it. this will start built-in cache server.

  2. create DistributedMapCacheClientService with hostname localhost and other default parameters and enable it

  3. create a simple flow GenerateFlowFile set the run schedule and not zero bytes size in parameters. connect it to PutDistributedMapCache set Entry Identifier as Key01 and choose your DistributedMapCacheClientService

try to run it. and if port 4557 not used by other software the put cache should work. enter image description here

Tags:

Apache Nifi