Comment configurer un cache de carte distribué pour NiFi?

Question

Je suis tout nouveau à NiFi et simplement jouer avec des processeurs.

Je suis en train d'intégrer les processeurs Wait et Notify dans mes tests, mais je dois configurer une carte cache distribué (serveur et client?).

La documentation NiFi suppose un niveau de compréhension que je n'ai pas.

J'ai installé memcached sur mon ordinateur (macOS) et vérifié qu'il fonctionne sur le port 11211 (par défaut). J'ai créé un DistributedMapCacheClientService et DistributedMapCacheServer sous CONTROLLER SERVICES de NiFi, mais je reçois java.net.SocketTimeoutException & d'autres erreurs.

Y at-il un bon tutoriel sur ce sujet? Quelqu'un peut-il suggérer comment aller de l'avant?

Answer 1

le DistributedMapCacheClientService et DistributedMapCacheServer ne nécessite pas de logiciel supplémentaire.

1. créer DistributedMapCacheServer avec les paramètres par défaut (port 4557) et l'activer. cela va démarrer le serveur de cache intégré.

2. créer DistributedMapCacheClientService avec le nom d'hôte localhost et d'autres paramètres par défaut et l'activer

3. créer un simple flux GenerateFlowFile définir la taille run schedule et non zéro octets dans les paramètres. connecter à PutDistributedMapCache définir Entry Identifier comme Key01 et choisissez votre DistributedMapCacheClientService

essayer de l'exécuter. et si le port 4557 n'est pas utilisé par un autre logiciel, le cache de mise doit fonctionner.