[
https://issues.apache.org/jira/browse/FLUME-3100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16024330#comment-16024330
]
ASF GitHub Bot commented on FLUME-3100:
---------------------------------------
GitHub user stakafum opened a pull request:
https://github.com/apache/flume/pull/137
[FLUME-3100] Support arbitrary header substitution for topic of Kafka
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/stakafum/flume FLUME-3100
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flume/pull/137.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #137
----
commit 09d59d761d300aa683bf39a7c58578d1daafdedd
Author: stakafum <[email protected]>
Date: 2017-05-25T06:23:44Z
[FLUME-3100] Support arbitrary header substitution for topic of Kafka
----
> Support arbitrary header substitution for topic of Kafka
> --------------------------------------------------------
>
> Key: FLUME-3100
> URL: https://issues.apache.org/jira/browse/FLUME-3100
> Project: Flume
> Issue Type: Improvement
> Components: Sinks+Sources
> Reporter: Takafumi Saito
> Priority: Minor
>
> Kafka Sink supports arbitrary header substitution which replace a substring
> ${A} in "kafka.topic" property with a value of header named “A”.
> Using the substitution become possible to dynamically select the topic by
> combining one or more values of event headers.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
