You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flume.apache.org by "Ashish Paliwal (JIRA)" <ji...@apache.org> on 2015/01/18 07:45:35 UTC

[jira] [Commented] (FLUME-2580) Sink side interceptors

    [ https://issues.apache.org/jira/browse/FLUME-2580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14281681#comment-14281681 ] 

Ashish Paliwal commented on FLUME-2580:
---------------------------------------

[~hshreedharan] This seems to be duplicate of FLUME-1207? May be we can mark one of them as duplicate.

> 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)