You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flume.apache.org by "Vitaly Rudensky (JIRA)" <ji...@apache.org> on 2016/01/25 21:14:39 UTC
[jira] [Comment Edited] (FLUME-2721) Add support for custom
serializer in Kafka Sink
[ https://issues.apache.org/jira/browse/FLUME-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15115896#comment-15115896 ]
Vitaly Rudensky edited comment on FLUME-2721 at 1/25/16 8:14 PM:
-----------------------------------------------------------------
I believe it make sense to use *org.apache.flume.serialization.EventSerializer* as "serializer" instead of Kafka specific one.
was (Author: 0xcafebabe):
I believe it make sense to use org.apache.flume.serialization.EventSerializer as "serializer" instead of Kafka specific one.
> Add support for custom serializer in Kafka Sink
> -----------------------------------------------
>
> Key: FLUME-2721
> URL: https://issues.apache.org/jira/browse/FLUME-2721
> Project: Flume
> Issue Type: Improvement
> Components: Sinks+Sources
> Affects Versions: v1.6.0
> Reporter: Benjamin Fiorini
> Attachments: FLUME-2721-0.patch
>
>
> In 1.6.0, the Kafka sink just sends the content of the body. It would be really cool to be able to have a custom serializer.
> My use case is that I'd like to send some headers as well, or better send the event serialized in JSON: {code}{"headers":{...},"body":"..."}{code}. There could be: body serializer (current behaviour) and JSON serializer.
> Will try to submit a patch soon if this makes sense.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)