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.
