Wie wird ein Distributed Map Cache für NiFi eingerichtet?

Question

Ich bin neu bei NiFi und spiele einfach mit Prozessoren.

Ich versuche Wait und Notify Prozessoren in meinen Tests zu übernehmen, aber ich habe ein Distributed Map-Cache Einrichtung (Server und Client?).

Die NiFi-Dokumentation geht von einem Verständnis aus, das ich nicht habe.

Ich habe Memcached auf meinem Computer (Mac OS) installiert und verifiziert, dass es auf Port 11211 läuft (Standard). Ich habe eine DistributedMapCacheClientService und DistributedMapCacheServer unter NiFi CONTROLLER SERVICES erstellt, aber ich bekomme java.net.SocketTimeoutException & andere Fehler.

Gibt es ein gutes Tutorial zu diesem ganzen Thema? Kann jemand vorschlagen, wie man vorwärts geht?

Answer 1

Die DistributedMapCacheClientService und DistributedMapCacheServer erfordert keine zusätzliche Software.

1. Erstellen Sie DistributedMapCacheServer mit Standard-Parameter (Port 4557) und aktivieren Sie es. Dies startet den integrierten Cache-Server.

2. erstellen DistributedMapCacheClientService mit Hostnamen localhost und anderen Standardparametern und ermöglicht es

3. GenerateFlowFile die run schedule und nicht null Byte Größe in Parametern ein einfaches Fluss erstellen. verbinden Sie es mit PutDistributedMapCache gesetzt Entry Identifier als Key01 und wählen Sie Ihre DistributedMapCacheClientService

versuchen, sie auszuführen. und wenn Port 4557 nicht von anderer Software verwendet wird, sollte der Put-Cache funktionieren.