Created question in FIWARE Q/A platform on 08-03-2017 at 17:03
Please, ANSWER this question AT https://stackoverflow.com/questions/42676814/adding-apache-flume-elastic-search-sink

Question:
adding Apache flume elastic search sink

Description:
I want to use Apache flume Elastic search native sink in cygnus.
How can I configure cygnus to use this native sink?

Do I put the native jar file in Apache flume lib and configure the agent as the folowing:

1. Name the components on this agent
   a1.sources = r1
   a1.sinks = k1
   a1.channels = c1

1. Describe/configure the source
   a1.sources.r1.type = netcat
   a1.sources.r1.bind = localhost
   a1.sources.r1.port = 44444

1. Describe the sink
   a1.sinks.k1.type = logger

1. Use a channel which buffers events in memory
   a1.channels.c1.type = memory
   a1.channels.c1.capacity = 1000
   a1.channels.c1.transactionCapacity = 100

1. Bind the source and sink to the channel
   a1.sources.r1.channels = c1
   a1.sinks.k1.channel = c1

and then I start two cygnus instance one with for cygnus-ngsi agent and the other for elastic search native sink?
Can't find how to run a cygnus instance (I installed cygnus from sources so I can't use linux services to start it)

And is it possible to use the same source for cygnus-ngsi and this new sink? cause I need the same source for both.

Thanks and best regards.