@rafy    Try this: ${DATE_TIME:toDate('yyyy-MM-dd HH:mm:ss.SSSSSSSSS'):format('dd/MM/yyyy HH:mm:ss.SSSSSS')}   Cheers, André ... View more

Then the service will be unavailable until you recover at least one of them. ... View more

@Big-dAta ,   A quorum in a ZooKeeper ensemble is a group of servers with more than half of the total number of servers in the ensemble. So for an ensemble of 5 servers, the quorum is 3 servers.   As long as there are 3 servers available an election can always be carried out. So, in your example, the 4 remaining servers will talk to each other and decide who will be the new leader.   Cheers, André   ... View more

@RB764 ,   Ok, I see. In the case of running JS code on the browser client, it makes sense to see the errors that you are seeing. That's exactly what CORS restrictions are designed for.   Are you loading this script from a file locally on your computer or is this part from a web application that you have running on a server?   If this is local to your computer, I would recommend that you use some other language to interact with NiFi, since running this locally on a browser has limitations. In Python, for example, you can use the nipyapi module, which makes it really easy to interact with the NiFi API:   from nipyapi import config, security from nipyapi.nifi.apis.flow_api import FlowApi config.nifi_config.host = 'https://<<server host:port>>/nifi-api' security.set_service_ssl_context(service='nifi', ca_file='<</path/to/truststore.pem>>') security.service_login(service='nifi', username='<<user>>', password='<<pwd>>') api = FlowApi() summary = api.get_cluster_summary()   If what you are trying to do is part of a web application, the interaction between application and NiFi should happen on the server side instead of the browser. This would also eliminate any sort of CORS issues.   Cheers, André   ... View more

@AbhishekSingh ,   The CaptureChangeMySQL processor acts as a MySQL replication slave. It requires the   REPLICATION_SLAVE   privilege in MySQL.   Following the steps in the documentation and create a separate user to use in your processor.   Cheers, André     Cheers, André ... View more

@ChuckE ,   You can use a JoltTransformRecord processor to perform the conversion to JSON and, at the same time, add the root node back to it.   The JOLT specification I used is this: { "*": "a.&" }   Cheers, André     ... View more

@SandyClouds ,   You don't need a MySQL replication server. What I meant is that the  CaptureChangeMySQL act as a replication client, and needs the same privileges as one.   I tested the exact same commands that you specified above and I was able to connect to the database from the command line: [root@cdp ~]# mysql -u replication -p Enter password: Welcome to the MySQL monitor. Commands end with ; or \g. Your MySQL connection id is 11 Server version: 8.0.26 Source distribution Copyright (c) 2000, 2021, Oracle and/or its affiliates. Oracle is a registered trademark of Oracle Corporation and/or its affiliates. Other names may be trademarks of their respective owners. Type 'help;' or '\h' for help. Type '\c' to clear the current input statement. mysql>   I was also able to configure the CaptureChangeMySQL processor to capture changes without any other privileges being granted:   Which version of MySQL are you using? There seems to be some issue with your user creation. The connection from the command line should work. What was the command you used to connect to the db using the replication user?   Could you please provide the configuration of your processor?   Cheers, André   ... View more

@Brenigan ,   1. It depends on the context and the level of &n. In the example above, &1 return the element in the transports array (e.g. "PUSH"), while &2 returns the numeric index of that element in the array (e.g. 0).   2. &4 and &2 are numeric array indexes. outer[&4] means that the output will be in the &4 position of an array called outer. That element of the array will have and attribute called inner and the &2 position of the inner array will have two attributes, t and etc, with the specified values.   Cheers, André ... View more

@AbhishekSingh ,   1. No, the NiFi Toolkit is not mandatory. If you're familiar with TLS certificates and NiFi administration you can set up and manage the cluster without it. The toolkit makes some of the activities easier, though. 2. What do mean by " flowfile change restriction "?   Cheers, André   ... View more