You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flume.apache.org by "Takafumi Saito (JIRA)" <ji...@apache.org> on 2019/04/03 09:59:00 UTC

[jira] [Created] (FLUME-3327) Add method to convrt headers of flume event and ones of kafka record transparently.

Takafumi Saito created FLUME-3327:
-------------------------------------

             Summary: Add method to convrt headers of flume event and ones of kafka record transparently.
                 Key: FLUME-3327
                 URL: https://issues.apache.org/jira/browse/FLUME-3327
             Project: Flume
          Issue Type: Improvement
          Components: Kafka Channel, Sinks+Sources
            Reporter: Takafumi Saito


The only way of delivering headers in flume event to kafka now is serializing event as Avro format of Flume and set it body of kafka. 
In kafka 0.11.0.0, record header is released as new feature.
If using headers of flume and one of kafka transparently, we do not need to serialize event.
We add `useKafkaHeader` option to select using record headers of kafka or not.
By default, the useKafkaHeader option is false because of considering compatibility.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@flume.apache.org
For additional commands, e-mail: issues-help@flume.apache.org