You want to use the ReplaceText processor [1] on each of the messages after they are consumed from Kafka. Set the "Replacement Strategy" to "Append" and the dynamic property to use Expression Language[2] to set the timestamp (ie. "${now()}"). Then merge the messages before sending the HDFS like normal. [1] https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi.processors.standard.ReplaceText/index.html [2] https://nifi.apache.org/docs/nifi-docs/html/expression-language-guide.html ... View more

Currently Fractional (aka. "Decimal") numbers are not supported in Expression Language. The "Number" field is backed by java Longs which are only whole numbers. There is currently work being done to add it and relatively recently there was a discussion thread about it[1]. The exact time when it will be included is yet to be determined though. Edit: Actually I shouldn't make the assumption "fractional == decimal". There are currently no plans to support decimals expressed as fractions, ie. "1/4". There are plans to support decimals expressed using decimal points, ie "0.25". If decimals expressed as fractions is what you need, could you share the use-case? [1] http://apache-nifi-developer-list.39713.n7.nabble.com/Discuss-Expression-Language-Options-to-Add-Decimal-Support-td9432.html ... View more

The GetHttp processor does not allow incoming connections. If you would like to dynamically change the URL in response to the attributes of FlowFiles I'd suggest using the InvokeHttp[1] processor instead of GetHttp. [1] https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi.processors.standard.InvokeHTTP/index.html ... View more

Hello, The GetEmail processor is slated to be in the 0.6.0 release and the ticket is here[1]. If you'd like to help shape the direction of the processor please feel free to comment on the ticket. [1] https://issues.apache.org/jira/browse/NIFI-1148 ... View more