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/remotes/origin/camel-2.13.x Commit: b840c4dd265e1c1a9d1c0246de5ca4b8fa83ca6f Parents: daccc8e Author: john.shields <john.shie...@tubemogul.com> Authored: Thu Sep 25 21:15:16 2014 -0500 Committer: Claus Ibsen <davscl...@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(); }