Hello, I have a NIFI (x2) Cluster with external zookeepers (x3). I'm testing my configuration and writing my admin guide for the production team. When i'm using zkCli, i can see 2 Primary Node (the same for Cluster Coord): [zk: localhost:2181(CONNECTED) 0] ls "/nifi/leaders/Primary Node" [_c_d77fe908-bfc9-41fe-9cc1-e7399483414a-lock-0000000001, _c_6aa6364e-a2cd-49b1-94ff-e201e68e058e-lock-0000000003] Questions : 1/ Why two IDs ? I was expecting only one. (On my staging, i have only one with the same conf) 2/ What does mean these IDs ? Can i correlate with the nifi node ? Any clue would be appreciated. ... View more

With NIFI 1.7.0 (windows 10, jre8) i'm trying to consume message from CloudAMPQ using AMQPS (amqp / tls) My URI is : amqps://xmabtrto:xxxxxxxxxx@sheep.rmq.cloudamqp.com/xmabtrto With processor executeScript + groovy : OK (but i do not pool connection, so it is low-perf...) With processor ConsumeAMQP : KO Bulletin : Failed to establish connection with AMQP Broker: com.rabbitmq.client.ConnectionFactory@2a835d25; My ConsumeAMQP settings are : host : sheep.rmq.cloudamqp.com virtualhost : xmabtrto user : xmabtrto port : 5671 (5672 works since it is plain amqp). SSL Context Service : no value Use Certificate Authentication : false Client Auth : REQUIRED I've tried using an SSL Context generated by the toolkit but it doesn't work neither (and i don't want to auth with cert). Working executeScript groovy code : import com.rabbitmq.client.* import org.apache.commons.io.IOUtils import java.nio.charset.* def factory = new ConnectionFactory(); factory.setUri("amqps://xmabtrto:xxxxxxxxxx@sheep.rmq.cloudamqp.com/xmabtrto"); def conn = factory.newConnection(); def channel = conn.createChannel() //... channel.close() conn.close() Any idea how to make ConsumeAMQP works with amqps ? ... View more