[
https://issues.apache.org/jira/browse/FLUME-3100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047679#comment-16047679
]
ASF subversion and git services commented on FLUME-3100:
--------------------------------------------------------
Commit 83e25691dc5f32d020b122d679b6f124162e4aef in flume's branch
refs/heads/trunk from [~Takafumi Saito]
[ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=83e2569 ]
FLUME-3100. Support arbitrary header substitution for topic of Kafka Sink
This patch adds the ability of header substitution n Kafka Sink's
kafka.topic configuration variable.
This closes #137.
Reviewers: Denes Arvay
(Takafumi Saito via Denes Arvay)
> 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.4.14#64029)
