[camel] branch master updated: CAMEL-12090: camel-kafka - Better error if brokers not configured

[davsclaus]

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/master by this push:
     new b0fbf95  CAMEL-12090: camel-kafka - Better error if brokers not 
configured
b0fbf95 is described below

commit b0fbf955fcbcbf115b1c48d96d4339f903802c39
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Dec 18 13:42:20 2017 +0100

    CAMEL-12090: camel-kafka - Better error if brokers not configured
---
 .../src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java  | 3 +++
 .../src/main/java/org/apache/camel/component/kafka/KafkaProducer.java  | 3 +++
 2 files changed, 6 insertions(+)

diff --git 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
index 63c9da3..b8b2d0c 100644
--- 
a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
+++ 
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java
@@ -76,6 +76,9 @@ public class KafkaConsumer extends DefaultConsumer {
         if (brokers == null) {
             brokers = endpoint.getComponent().getBrokers();
         }
+        if (brokers == null) {
+            throw new IllegalArgumentException("URL to the Kafka brokers must 
be configured with the brokers option on either the component or endpoint.");
+        }
 
         props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, brokers);
 
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 5d7eaff..3ba0658 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
@@ -61,6 +61,9 @@ public class KafkaProducer extends DefaultAsyncProducer {
         if (brokers == null) {
             brokers = endpoint.getComponent().getBrokers();
         }
+        if (brokers == null) {
+            throw new IllegalArgumentException("URL to the Kafka brokers must 
be configured with the brokers option on either the component or endpoint.");
+        }
         props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, brokers);
 
         return props;

-- 
To stop receiving notification emails like this one, please contact
['"commits@camel.apache.org" <commits@camel.apache.org>'].