Viktor Gerdin created FLUME-3081:
------------------------------------
Summary: KafkaSource outputs offset in header
Key: FLUME-3081
URL: https://issues.apache.org/jira/browse/FLUME-3081
Project: Flume
Issue Type: Improvement
Affects Versions: 1.7.0, 1.8.0
Reporter: Viktor Gerdin
Priority: Minor
In FLUME-2799 the original request included (amongst others) Kafka offset to be
part of the message headers from the KafkaSource. However the ticket was
resolved without it. In affected versions the possible headers are:
* topic
* partition
* key
* timestamp (agent JVM system time)
I propose to add offset in order to make a traceable system key
(topic+partition+offset) in order to synchronise between several consumers
(something necessary for my case).
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
