Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- InstanceSpec spec = new InstanceSpec(null, -1, -1, -1, true, -1, 2000, 10);
- System.setProperty("zookeeper.serverCnxnFactory", "org.apache.zookeeper.server.NettyServerCnxnFactory");
- myKeeper = new TestingServer(spec);
- String keeperPort = String.valueOf(spec.getPort());
- System.setProperty("zk.servers", "localhost:" + keeperPort);
- zkClient = CuratorFrameworkFactory.builder()
- .sessionTimeoutMs(60000)
- .connectionTimeoutMs(10000)
- .connectString("localhost:" + keeperPort)
- .retryPolicy(new RetryOneTime(1000))
- .defaultData(null)
- .build();
- zkClient.start();
Add Comment
Please, Sign In to add comment