Thanks Sandeep & Hari your help is much appreciated.
I kept having build errors on the TestAsyncHBaseSink test but rather than
ignoring them I tried the 1.5.0.1 binaries which worked perfectly first
time.
On Fri, Aug 29, 2014 at 7:23 PM, Hari Shreedharan wrote:
> How are you using Flume? If yo
It could be useful for you this project [1] the side where the source
is converted to avro using a custom parser.
[1] https://github.com/danieltardon/flume-ng-kafka-avro-sink
On Fri, Aug 29, 2014 at 5:18 PM, Ed Judge wrote:
> From initial reading of what it does, it look promising. So, I could
Hello
Is it possible for the elasticsearch sink ?:
Have the option to disable the suffix appended, ie -MM-DD
Have dynamic indexname derived from a avro header
Have dynamic indextype also like above
Thx
Jean