I would choose customer sink since the event could be taken out from the channel after and this eliminates the requirement for the channel space.
PS: Flume’s customer sink is very simple to implement. The following is one of the simplest example https://github.com/meou/flume-file-sink/blob/master/src/main/java/org/meou/flume/sink/file/TextFileSink.java BR, Shang On 4/12/17, 8:32 AM, "Felipe Dino" <dino....@gmail.com> wrote: Hello, I need to develop a solution that consumes a message from a kafka queue, does a treatment and writes again on another kafka topic. My question is: For greater performance, should I treat the message in a custom interceptor or custom sink? Grateful. Felipe Naberezny
