Skip to content

Instantly share code, notes, and snippets.

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
You can’t perform that action at this time.