Implementing a Flume Sink -

Therefore, I need to implement my own flue sync. I went through this, but my only missing The part is, I'm doing it once with my Java implementation. It's a Compile in class? Jar? And how do I configure Flume to use my custom sync?

Thanks

compile it and package it in a jar. Then & lt; Apache flume install dir> Insert / lib . Then you can refer to your class with your fully qualified name in the sync definition.