[
https://issues.apache.org/jira/browse/FLUME-2251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14130887#comment-14130887
]
Gwen Shapira commented on FLUME-2251:
-------------------------------------
[~hshreedharan] - agree on most comments on working to fix them.
However, regarding the last one, the preProcessor is most definitely a
preProcessor and not a serializer.
It actually does actions that may be a better fit for an interceptor -
modifying the message, processing it to decide on a topic and partition into
which the message will be published.
Any advice on whether to remove this functionality and instead check event
header for topic and partition information (so the interceptor can be used for
this functionality)?
> Add support for Kafka Sink
> --------------------------
>
> Key: FLUME-2251
> URL: https://issues.apache.org/jira/browse/FLUME-2251
> Project: Flume
> Issue Type: Sub-task
> Components: Sinks+Sources
> Affects Versions: v1.4.0
> Reporter: Ashish Paliwal
> Priority: Minor
> Labels: feature, patch
> Attachments: FLUME-2251-0.patch, FLUME-2251-2.patch,
> FLUME-2251-3.patch, FLUME-2251.patch, FLUME-2251.patch, Flume-2251-1.patch
>
>
> Add support for Kafka Sink
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
