[
https://issues.apache.org/jira/browse/FLUME-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14306902#comment-14306902
]
Hari Shreedharan commented on FLUME-2580:
-----------------------------------------
I'd like to keep the discussion on the jira. Using a Google doc causes the
discussion to be off jira and very untrackable.
With the sink side interceptors it would not be possible to do batch, because
the sink pulls events out one by one. Batch intercept will have to wait for a
new interface.
> 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)
