diff --git a/stream/distributedlog/core/src/main/java/org/apache/distributedlog/LocalDLMEmulator.java b/stream/distributedlog/core/src/main/java/org/apache/distributedlog/LocalDLMEmulator.java
index dc014f1..61bc231 100644
--- a/stream/distributedlog/core/src/main/java/org/apache/distributedlog/LocalDLMEmulator.java
+++ b/stream/distributedlog/core/src/main/java/org/apache/distributedlog/LocalDLMEmulator.java
@@ -308,13 +308,22 @@
     public static void main(String[] args) throws Exception {
         try {
             if (args.length < 1) {
-                System.out.println("Usage: LocalDLEmulator <zk_port>");
+                System.out.println("Usage: LocalDLEmulator [<zk_host>] <zk_port>");
                 System.exit(-1);
             }
 
-            final int zkPort = Integer.parseInt(args[0]);
+            String zkHost = DEFAULT_ZK_HOST;
+            int zkPort = DEFAULT_ZK_PORT;
+            if (args.length == 1) {
+                zkPort = Integer.parseInt(args[0]);
+            } else {
+                zkHost = args[0];
+                zkPort = Integer.parseInt(args[1]);
+            }
+
             final File zkDir = IOUtils.createTempDir("distrlog", "zookeeper");
             final LocalDLMEmulator localDlm = LocalDLMEmulator.newBuilder()
+                .zkHost(zkHost)
                 .zkPort(zkPort)
                 .build();
 
@@ -334,7 +343,7 @@
 
             System.out.println(String.format(
                 "DistributedLog Sandbox is running now. You could access distributedlog://%s:%s",
-                DEFAULT_ZK_HOST,
+                zkHost,
                 zkPort));
         } catch (Exception ex) {
             System.out.println("Exception occurred running emulator " + ex);