This is Flume-NG Sink for Elasticsearch = 2.3.* I developed this because the official version does not support Elasticsearch 2.3.* due to API changes.
- Flume-NG = 1.8
- Elasticsearch = 2.3.*
Build fat jar which contains elasticsearch dependencies
$ gradle assemblyJar will be generated in build/libs
- Append the built jar to Flume's classpath
- remove
guava-*.jarandjackson-core-*.jarin flume's default libs dir. They are outdated and newer version are included in Elasticsearch. - set sink type to
com.dwt.flume.sink.elasticsearch2.ElasticSearchSinkin flume.conf - start flume agent