Repository: kafka Updated Branches: refs/heads/0.10.0 76fa376e2 -> 18f643b82
MINOR: Move connect.start() to try catch block Author: Liquan Pei <[email protected]> Reviewers: Ewen Cheslack-Postava <[email protected]> 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/18f643b8 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/18f643b8 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/18f643b8 Branch: refs/heads/0.10.0 Commit: 18f643b82b05904516295e2734af0d8a9fb053ea Parents: 76fa376 Author: Liquan Pei <[email protected]> Authored: Sun May 8 23:52:13 2016 -0700 Committer: Ewen Cheslack-Postava <[email protected]> Committed: Sun May 8 23:52:56 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/18f643b8/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>>() {
