[
https://issues.apache.org/jira/browse/FLUME-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hari Shreedharan updated FLUME-2580:
------------------------------------
Attachment: SinkSideInterceptors.pdf
Here is a design document for this. This is what I could come up with, bearing
in mind that current components should not break.
We can think of a Sink 2.0 interface, which can make this much simpler, but
that is for a later time.
> Sink side interceptors
> ----------------------
>
> Key: FLUME-2580
> URL: https://issues.apache.org/jira/browse/FLUME-2580
> Project: Flume
> Issue Type: New Feature
> Reporter: Hari Shreedharan
> Assignee: Hari Shreedharan
> Attachments: SinkSideInterceptors.pdf
>
>
> Currently, we only have source-side interceptors that help routing. But if we
> use something like Kafka Channel, having a sink-side interceptor can help us
> modify events as they come in. We could also do validation on event schemas
> and drop them before they hit the sink, rather than have an infinite loop due
> to such events.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
