Fixed potential NPE
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/9efa1cb8 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/9efa1cb8 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/9efa1cb8 Branch: refs/heads/camel-2.15.x Commit: 9efa1cb8509bad618497b6c765e06f57623bfc7b Parents: 4550215 Author: Claus Ibsen <[email protected]> Authored: Tue Jul 7 14:49:19 2015 +0200 Committer: Claus Ibsen <[email protected]> Committed: Tue Jul 7 14:50:02 2015 +0200 ---------------------------------------------------------------------- .../java/org/apache/camel/component/kafka/KafkaProducer.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/9efa1cb8/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 c598cf9..b832740 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 @@ -48,7 +48,9 @@ public class KafkaProducer extends DefaultProducer { Properties getProps() { Properties props = endpoint.getConfiguration().createProducerProperties(); - props.put("metadata.broker.list", endpoint.getBrokers()); + if (endpoint.getBrokers() != null) { + props.put("metadata.broker.list", endpoint.getBrokers()); + } return props; }
