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 2014/09/27 13:23:36 UTC
[7/7] git commit: CAMEL-7864: Updates to allow setting Kafka's
zookeeper.connect directly.
CAMEL-7864: Updates to allow setting Kafka's zookeeper.connect directly.
- Fixed a few accidental tabs...
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/b840c4dd
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/b840c4dd
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/b840c4dd
Branch: refs/heads/camel-2.13.x
Commit: b840c4dd265e1c1a9d1c0246de5ca4b8fa83ca6f
Parents: daccc8e
Author: john.shields <jo...@tubemogul.com>
Authored: Thu Sep 25 21:15:16 2014 -0500
Committer: Claus Ibsen <da...@apache.org>
Committed: Sat Sep 27 13:23:19 2014 +0200
----------------------------------------------------------------------
.../java/org/apache/camel/component/kafka/KafkaEndpoint.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/b840c4dd/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
index deed68a..af1bcd1 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaEndpoint.java
@@ -103,13 +103,13 @@ public class KafkaEndpoint extends DefaultEndpoint {
//-------------------------------------------------------------------------
public String getZookeeperConnect() {
- return configuration.getZookeeperConnect();
+ return configuration.getZookeeperConnect();
}
public void setZookeeperConnect(String zookeeperConnect) {
- configuration.setZookeeperConnect(zookeeperConnect);
- }
-
+ configuration.setZookeeperConnect(zookeeperConnect);
+ }
+
public String getZookeeperHost() {
return configuration.getZookeeperHost();
}