Instantly share code, notes, and snippets.

Embed
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,...
@Value("${zookeeperService.hosts:localhost}")
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)
startServer(serverStarter)
} else {
log.info("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