Last active

Embed URL

HTTPS clone URL

SSH clone URL

You can clone with HTTPS or SSH.

Download Gist

start Zookeeper client

View zkClientStartup.scala
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
def initialize() {
// Embedded server startup here (see part 2)
// ...
curatorFramework =
CuratorFrameworkFactory.newClient(
connectString, sessionTimeoutSec*1000,
connectionTimeoutSec*1000, new RetryOneTime(1))
curatorFramework.start()
curatorFramework.getZookeeperClient.blockUntilConnectedOrTimedOut()
if (!curatorFramework.isStarted) {
throw new Exception(
"Connection to Zookeeper timed out after " + connectionTimeoutSec + " seconds")
}
selectLeader()
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Something went wrong with that request. Please try again.