[FLUME-2721] Add support for custom serializer in Kafka Sink

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.6.0
• Component/s: Sinks+Sources
• Assignee: Unassigned
• Reporter: Benjamin Fiorini
• Created: 17/Jun/15 08:35
• Updated: 25/Jan/16 20:14

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:

{"headers":{...},"body":"..."}

. There could be: body serializer (current behaviour) and JSON serializer.

Will try to submit a patch soon if this makes sense.