•  13-10-2022
  •  | 
  •  

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

Was it helpful?

Solution

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.

Licensed under: CC-BY-SA with attribution
Not affiliated with StackOverflow
scroll top