[
https://issues.apache.org/jira/browse/FLUME-2721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Benjamin Fiorini updated FLUME-2721:
------------------------------------
Description:
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.
was:
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: {"headers":{...},"body":"..."}. There could be: body
serializer (current behaviour) and JSON serializer.
Will try to submit a patch soon if this makes sense.
> 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
>
> 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)
