Tristan Stevens created FLUME-2852:
--------------------------------------
Summary: Kafka Source/Sink should optionally read/write Avro Datums
Key: FLUME-2852
URL: https://issues.apache.org/jira/browse/FLUME-2852
Project: Flume
Issue Type: Improvement
Components: Sinks+Sources
Affects Versions: v1.6.0
Reporter: Tristan Stevens
Currently the Kafka Sink only writes the event body to Kafka rather than an
Avro Datum. This works fine when being used with a Kafka Source, or when being
used with Kafka Channel, however it does mean that any Flume headers are lost
when transported via Kafka.
Request is to implement an equivalent of the Kafka Channel's parseAsFlumeEvent
parameter to the sink/source so that optionally Avro Datums can be read from
and written to Kafka.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
