Implementing a Flume Sink

Question

So, I need to implement my own Flume sink. I went through this link, but my only missing part is, what do I exactly do once I am done with my Java implementation? Compile it into a .class? JAR? and how to I configure Flume to use my custom sink?

Thanks

Answer 1

Compile it and package it into a jar. Then put the jar in <apache flume install dir>/lib. Then you can refer to your class with its fully qualified name in a sink definition.