Details
-
Improvement
-
Status: Open
-
Major
-
Resolution: Unresolved
-
1.6.0
-
None
-
None
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.