About Fanxxx

Fanxxx · ‎02-19-2024

I have a three node NIFI setup and I want to establish a TCP connection channel with an external system to send and recieve data on a single channel how can that be achieved ?

Fanxxx · ‎11-28-2023

Hi @cotopaul , Thanks for the input, can you help on how to setup the invokeHTTP processor and how to fetch all the queues that we were not able to find in the Mongo DB.

Fanxxx · ‎11-20-2023

I am using the GetMongo processor to query a mongoDB for a particular key value pair and if the data is found then I want to log that But if the data is not found in the DB then I want to use the same key value pair (already present in the attributes of each flow file) that is failed and input into the next processor how can I approach this issue.

Fanxxx · ‎11-09-2023

I have created a three node NIFI cluster and the embedded zookeeper is set up and all the three nodes are communicating with each other through heartbeats but when I try to access the NIFI UI I am getting the below error: Unauthorized error="invalid_token", error_description="An error occurred while attempting to decode the Jwt: Signed JWT rejected: Another algorithm expected, or no matching key(s) found", error_uri="https://tools.ietf.org/html/rfc6750#section-3.1" How do I fix this issue?

Fanxxx · ‎11-01-2023

I want to split this json {"id": "652fbf430f1f3f30a3111f11,652fbf430f1f3f30a3333f11", "Qid": 123} into {"id": "652fbf430f1f3f30a3111f11", "Qid": 123} and {"id": "652fbf430f1f3f30a3333f11","Qid": 123} using Apache Nifi in the above example we have two id values there can be multiple values as well then I want to add these id values to the attribute of the two flow files that are created from the split JSONs.

Fanxxx · ‎10-18-2023

I have to make a flow where I want to check that two Mongo DBs are in sync so everyday I have to compare the count of records that are being inserted into both the DBs if there is a discrepancy I want to transfer the records from the main DB to the DB which doesn't have it. Both DBs have a created AT key which has the date when the record was added. I want to achieve this through apache NIFI.

Fanxxx · ‎06-27-2023

I want to execute export command to take the PSQL dump of the database and transfer it using NIFI and the execute the import command at the destination db. can anyone provide a flow to do so ?

Fanxxx · ‎06-19-2023

Embedded zookeeper is failing to start while setting up a three node cluster for NIFI. The error message indicates that there is an issue with starting the embedded Zookeeper server while starting NiFi on your three-node cluster. The specific error causing the problem is "Address already in use," which suggests that the port required by Zookeeper is already occupied by another process. How can I solve this issue?

Online	Offline
Last Visited	‎06-28-2024 10:00 AM

Member Since	‎06-19-2023 02:41 AM
Last Visited	‎06-28-2024 10:00 AM
Posts	8
Kudos received	1

Cloudera Community

TCP connection on NIFI

Re: Getmongo processor failure case

Getmongo processor failure case

JWT token issue while setting up three node NIFI c...

I have to split a json into two using nifi process...

Count number of incoming flow files

Execute export dump commands and transfer using ni...

Embedded zookeeper failing while setting up a thre...