Hi Simeon, I am facing the same problem. Did you find any solution ? Thanks, Deepak
On Wed, Mar 5, 2014 at 5:52 PM, Simeon Zaharici <[email protected]>wrote: > Hi guys > > I would like to send json data to a flume netcat source and then send it > to an elasticsearch sink that uses the > > org.apache.flume.sink.elasticsearch.ElasticSearchLogStashEventSerializer. > > It works to send plain text on the netcat source, however when I send json > the event ends up in elasticsearch as > *'*org.elasticsearch.common.xcontent.XContentBuilder'. > > Which would be the easiest way to go about this ? I saw from reading docs > that creating a morphline interceptor could be the way to go but I did not > fully understand how that > works. > > Thanks a lot > > -- Deepak Subhramanian
