Skip to content

Instantly share code, notes, and snippets.

Last active December 13, 2015 21:59
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
Star You must be signed in to star a gist
What would you like to do?
class ZookeeperService(hostInfo: HostInfo)
extends ClusterService with EmbeddedZookeeper with Logging {
// For Standalone use the hostname, eg. localhost
// For Replicated use hostname:port,hostname:port,...
var hosts: String = _
// This node's ZK server client port
def clientPort: Int = hostInfo.appBasePort + 1
def initialize() {
val serverNames = genServerNames(hosts)
if (isServerEnabled) {
val serverStarter = configureServer(serverNames)
} else {"Embedded zookeeper server not enabled")
// Client startup
val connectString = serverNames.hosts.mkString(",")
// ...
// ... see part 1
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment