[
https://issues.apache.org/jira/browse/FLUME-3100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16047736#comment-16047736
]
Hudson commented on FLUME-3100:
-------------------------------
SUCCESS: Integrated in Jenkins build Flume-trunk-hbase-1 #249 (See
[https://builds.apache.org/job/Flume-trunk-hbase-1/249/])
FLUME-3100. Support arbitrary header substitution for topic of Kafka (denes:
[http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=83e25691dc5f32d020b122d679b6f124162e4aef])
* (edit)
flume-ng-sinks/flume-ng-kafka-sink/src/main/java/org/apache/flume/sink/kafka/KafkaSink.java
* (edit)
flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestConstants.java
* (edit) flume-ng-doc/sphinx/FlumeUserGuide.rst
* (edit)
flume-ng-sinks/flume-ng-kafka-sink/src/test/java/org/apache/flume/sink/kafka/TestKafkaSink.java
> 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
> Fix For: 1.8.0
>
>
> 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)
