Hi guys, I have some problem with my NIFI flow-I download records from Kafka, I split it to have single record per split-here i have round robin load balance.Next i add id attribute and then i divide the flow to two paths, on one I do some actions with http iinokes to have some new attributes.Next I clear the context on this path and I would like merge it back with this other path to have this json context and this attributes in one.I use merge content processoe for this, merging using the id attribute that I assigned at the beginning. And now I have a problem because it works but in the case of a larger number of records, eg. 200 it doesn't because I have an error BIN_MANAGER_FULL. Minimum Number of Entries is 2 and Maximum Number of Entries i have 2 too, while Maximum number of Bins is 10 and i would not like to increase it. Is there any way to bypass this and make it work for a larger number of records?For example apply the limit so that it merges only when there is space or wait for space?I will be grateful for tips on how to solve this problem   ... View more

Hi guys, I have some problem with public data on Kafka. I have record to public like this: { "name": "Jess", "surname": "Stone",  "data": { "mail": "j.stone@gmail.com", "class": "5",   "address": {   "country": "Brasil",   "city": "Rio de Janeiro"  } }, "anotherData": { "sex": "female", "code": "1220" } } I need set code value as key so I set it like  Message Key Field sex But it doesn't works, i think it is possible that it doesn't work because this value is nested-when I set for example name it works. Maybe you know how can I set these nested value from this record to Message Key Field? I tried something like this: anotherData.sex but it doesn't work too... ... View more

Hi guys, I am new in Nifi and I have some problem with authentication-I am using HandleHttpRequest to coolect some data from other system. I need to do some basic authorization. I know that it something like http.header.authentication but I have a few question about this: 1.How can get it to this authorization header? My first processor is HandleHTTPRequest so it is enough that my second processor will be  EvaluateJsonPath and I do something like this: $.http.headers.Authorization or I need do something else? 2. I heard that this authorization data are in Base64. How can I decode it and compere with my user and password when for example my user is user1 and password is password1 I will be grateful for tips because I don't know how to ho about it   ... View more