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/06/25 08:31:55 UTC
[2/3] camel git commit: CAMEL-8901: NBSP characters in
camel-kafka:KafkaConfiguration parameter. Thanks to Matt Henkel for the
patch.
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/5f7ff0df
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5f7ff0df
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5f7ff0df
Branch: refs/heads/camel-2.15.x
Commit: 5f7ff0dfc0518b6f5e4074293e750e8ac1addfeb
Parents: 7e3b351
Author: Claus Ibsen <da...@apache.org>
Authored: Thu Jun 25 08:34:49 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Jun 25 08:37:31 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/5f7ff0df/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 576cb9e..72a208b 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
@@ -166,9 +166,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;
}
@@ -178,7 +178,7 @@ public class KafkaConfiguration {
props.put(key, value.toString());
}
}
-
+
public String getZookeeperConnect() {
if (this.zookeeperConnect != null) {
return zookeeperConnect;
@@ -189,7 +189,7 @@ public class KafkaConfiguration {
public void setZookeeperConnect(String zookeeperConnect) {
this.zookeeperConnect = zookeeperConnect;
-
+
// connect overrides host and port
this.zookeeperHost = null;
this.zookeeperPort = -1;