CAMEL-8923 Use local var instead of getter again.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a9bad7b1 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a9bad7b1 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a9bad7b1 Branch: refs/heads/master Commit: a9bad7b1a06758f5dad72e436aed8dc6d21537e5 Parents: dc9e8eb Author: Raul Kripalani <ra...@apache.org> Authored: Wed Sep 2 23:32:13 2015 +0100 Committer: Raul Kripalani <ra...@apache.org> Committed: Wed Sep 2 23:32:13 2015 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/camel/component/kafka/KafkaProducer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/a9bad7b1/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java index 3bc8e78..06a0317 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaProducer.java @@ -66,7 +66,7 @@ public class KafkaProducer<K, V> extends DefaultProducer { public void process(Exchange exchange) throws CamelException { String topic = endpoint.getTopic(); if (!endpoint.isBridgeEndpoint()) { - topic = exchange.getIn().getHeader(KafkaConstants.TOPIC, endpoint.getTopic(), String.class); + topic = exchange.getIn().getHeader(KafkaConstants.TOPIC, topic, String.class); } if (topic == null) { throw new CamelExchangeException("No topic key set", exchange);
