[
https://issues.apache.org/jira/browse/FLUME-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hari Shreedharan updated FLUME-2580:
------------------------------------
Description: 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. (was: 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 channel, rather than have an infinite loop due to such events. )
> 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
>
> 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)
