You don’t necessarily need a custom processor for this. To convert the JSON to key values for a graph for example, you can use EvaluateJsonPath on your incoming messages from Kafka, this will pull out the pieces you need, then use AttributesToJson to select these attributes back into JSON to push to the PutElastic processor.
Simon > On 31 Mar 2016, at 12:20, idioma <corda.ila...@gmail.com> wrote: > > Hi, > I am very new to NiFi and I have the following flow: > > Consume Messages from Kafka based on a particular topic (JSON format) > ->Transform JSON format into some Titan-compliant format -> put them into > Titan/ElasticSearch on AWS > > I have done researching and I believe I can set use the standard processor > GetKafka and PutElasticSearch for the two "extremes" of the process flow. > Can you confirm this? Would I need to write my own processor? (I am working > with Java) I feel that I would need to write a Java processor for the actual > transformation from JSON format into a graph one. Is that correct? Any > suitable resource/project that can be useful to get me going with this? > > Thanks, > > I. > > > > -- > View this message in context: > http://apache-nifi-developer-list.39713.n7.nabble.com/Import-Kafka-messages-into-Titan-tp8647.html > Sent from the Apache NiFi Developer List mailing list archive at Nabble.com. >
