camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [3/3] camel git commit: CAMEL-8901: NBSP characters in camel-kafka:KafkaConfiguration parameter. Thanks to Matt Henkel for the patch.
Date Thu, 25 Jun 2015 06:31:56 GMT
CAMEL-8901: NBSP characters in camel-kafka:KafkaConfiguration parameter. Thanks to Matt Henkel
for the patch.


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/cae427c9
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/cae427c9
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/cae427c9

Branch: refs/heads/camel-2.14.x
Commit: cae427c959e5e7a7db13e28a1865851707ed573d
Parents: b508c4d
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Thu Jun 25 08:34:49 2015 +0200
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Thu Jun 25 08:37:44 2015 +0200

----------------------------------------------------------------------
 .../org/apache/camel/component/kafka/KafkaConfiguration.java | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/cae427c9/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
index 881ef3c..718710c 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConfiguration.java
@@ -116,9 +116,9 @@ public class KafkaConfiguration {
         addPropertyIfNotNull(props, "auto.offset.reset", getAutoOffsetReset());
         addPropertyIfNotNull(props, "consumer.timeout.ms", getConsumerTimeoutMs());
         addPropertyIfNotNull(props, "client.id", getClientId());
-        addPropertyIfNotNull(props, "zookeeper.session.timeout.ms ", getZookeeperSessionTimeoutMs());
+        addPropertyIfNotNull(props, "zookeeper.session.timeout.ms", getZookeeperSessionTimeoutMs());
         addPropertyIfNotNull(props, "zookeeper.connection.timeout.ms", getZookeeperConnectionTimeoutMs());
-        addPropertyIfNotNull(props, "zookeeper.sync.time.ms ", getZookeeperSyncTimeMs());
+        addPropertyIfNotNull(props, "zookeeper.sync.time.ms", getZookeeperSyncTimeMs());
         return props;
     }
 
@@ -128,7 +128,7 @@ public class KafkaConfiguration {
             props.put(key, value.toString());
         }
     }
-    
+
     public String getZookeeperConnect() {
         if (this.zookeeperConnect != null) {
             return zookeeperConnect;
@@ -139,7 +139,7 @@ public class KafkaConfiguration {
 
     public void setZookeeperConnect(String zookeeperConnect) {
         this.zookeeperConnect = zookeeperConnect;
-        
+
         // connect overrides host and port
         this.zookeeperHost = null;
         this.zookeeperPort = -1;


Mime
View raw message