Support Questions
Find answers, ask questions, and share your expertise

Issue with JsonQueryElasticSearch processor generating previous flowfile

Issue with JsonQueryElasticSearch processor generating previous flowfile

Explorer

Hello,

 

I was trying to implement the below flow in nifi

 

do a curl http request with search parameters for elasticSearch query and send response with result set via nifi.

 

Nifi Flow :

HandleHttpRequest --> EvaluateJsonPath (to get the required fields to pass them to ElasticSearch Query) --> JsonQueryElasticSearch --> Publish to Kafka -->  HandleHttpResponse

 

the JsonQueryElasticSearch works well giving me the correct result set.

Issue here is it generates an extra flow file from HandleHttpRequest processor along with the results set from elasticsearch. I am not sure how to ignore or delete or filter that flow file in order pass the data from JsonQueryElasticSearch to Publish Kafka processor or to HandleHttpResponse.

 

I wish i could share the flow xml file or the screenshot of the configuration unfortunately i cannot due to organization policies.

 

Please advise if there is any solution for this.

 

Thanks in Advance and appreciate your help.