Michael Andre Pearce created FLUME-2799:
-------------------------------------------
Summary: Kafka Source - Message Offset and Partition add to headers
Key: FLUME-2799
URL: https://issues.apache.org/jira/browse/FLUME-2799
Project: Flume
Issue Type: Improvement
Components: Sinks+Sources
Affects Versions: v1.6.0
Reporter: Michael Andre Pearce
Priority: Trivial
Currently Kafka source only persists the original kafka message's topic into
the Flume event headers.
For downstream interceptors and sinks that may want to have available to them
the partition and the offset , we need to add these.
Also it is noted that the conversion from MessageAndMetaData to FlumeEvent is
not configurable unlike other sources such as JMS.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
