Guest User

Untitled

a guest
Mar 17th, 2018
102
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.68 KB | None | 0 0
  1. InstanceSpec spec = new InstanceSpec(null, -1, -1, -1, true, -1, 2000, 10);
  2. System.setProperty("zookeeper.serverCnxnFactory", "org.apache.zookeeper.server.NettyServerCnxnFactory");
  3. myKeeper = new TestingServer(spec);
  4. String keeperPort = String.valueOf(spec.getPort());
  5. System.setProperty("zk.servers", "localhost:" + keeperPort);
  6. zkClient = CuratorFrameworkFactory.builder()
  7. .sessionTimeoutMs(60000)
  8. .connectionTimeoutMs(10000)
  9. .connectString("localhost:" + keeperPort)
  10. .retryPolicy(new RetryOneTime(1000))
  11. .defaultData(null)
  12. .build();
  13. zkClient.start();
Add Comment
Please, Sign In to add comment