Simple server to receive FlowFiles sent from a NiFi processor
Reference: https://issues.apache.org/jira/browse/NIFI-4037
-
Clone this repo.
-
Build a NiFi flow of
GenerateFlowFile
andInvokeGRPC
as described in the ticket above, but wait to enable the flow. -
Configure the
InvokeGRPC
as follows:-
remote host: localhost
-
remote port: Ensure that the port is the same as set here: https://github.com/m-hogue/nifi-grpc-server/blob/master/src/main/java/org/mikeyo/NifiFlowFileServer.java#L18
-
-
Configure the
GenerateFlowFile
processor to generate an abitrarily sized file at an arbitrary interval. I chose 30B @ every 5 seconds. -
Run the gRPC server main method in your IDE: https://github.com/m-hogue/nifi-grpc-server/blob/master/src/main/java/org/mikeyo/NifiFlowFileServer.java or run 'mvn exec:java'
-
Enable both the
GenerateFlowFile
andInvokeGRPC
processors. You should see the server log a message roughly every 5 seconds once the generated flow file has made it through the flow.