You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2015/07/07 14:43:57 UTC
[2/2] camel git commit: Fixed potential NPE
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 <da...@apache.org>
Authored: Tue Jul 7 14:49:19 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
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;
}