kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: MINOR: Move connect.start() to try catch block
Date Mon, 09 May 2016 06:52:33 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk dbafc631a -> fc89083f8


MINOR: Move connect.start() to try catch block

Author: Liquan Pei <liquanpei@gmail.com>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

Closes #1347 from Ishiihara/connect-standalone


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

Branch: refs/heads/trunk
Commit: fc89083f812a513699f5f0c02648f7a7927acf64
Parents: dbafc63
Author: Liquan Pei <liquanpei@gmail.com>
Authored: Sun May 8 23:52:13 2016 -0700
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Sun May 8 23:52:13 2016 -0700

----------------------------------------------------------------------
 .../java/org/apache/kafka/connect/cli/ConnectStandalone.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/fc89083f/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java
----------------------------------------------------------------------
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java
b/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java
index 4ade18c..b75783c 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java
@@ -77,9 +77,9 @@ public class ConnectStandalone {
 
         Herder herder = new StandaloneHerder(worker);
         final Connect connect = new Connect(herder, rest);
-        connect.start();
-
+        
         try {
+            connect.start();
             for (final String connectorPropsFile : Arrays.copyOfRange(args, 1, args.length))
{
                 Map<String, String> connectorProps = Utils.propsToStringMap(Utils.loadProps(connectorPropsFile));
                 FutureCallback<Herder.Created<ConnectorInfo>> cb = new FutureCallback<>(new
Callback<Herder.Created<ConnectorInfo>>() {


Mime
View raw message