public class KafkaZooKeeperSshDriver extends AbstractfKafkaSshDriver implements KafkaZooKeeperDriver
KEY_VAL_OPT_PREFIXES, MUTUALLY_EXCLUSIVE_OPTSCHECK_RUNNING, CUSTOMIZING, DEBUG, IGNORE_ENTITY_SSH_FLAGS, INSTALL_INCOMPLETE, INSTALLING, KILLING, LAUNCHING, logSsh, NON_STANDARD_LAYOUT, PID_FILENAME, PROCESS_OWNER, RESTARTING, STOPPING, USE_PID_FILE, VALID_FLAGS| Constructor and Description |
|---|
KafkaZooKeeperSshDriver(KafkaZooKeeperImpl entity,
SshMachineLocation machine) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.Integer |
getZookeeperPort() |
customize, getPidFile, getShellEnvironment, install, isRunning, launch, preInstall, stopcheckJavaHostnameBug, copyRuntimeResources, getJavaOpts, getJmxContext, getJmxPort, getRmiRegistryPort, installJava, installJmxSupport, isJmxEnabled, isJmxSslEnabled, setupcheckNoHostnameBug, copyInstallResources, copyResource, copyResource, execute, execute, execute, getAddress, getExpandedInstallDir, getHostname, getInstallDir, getLocation, getMachine, getPortsUsed, getRunDir, getSubnetAddress, getSubnetHostname, runPostInstallCommand, runPostLaunchCommand, runPreInstallCommand, runPreLaunchCommand, setExpandedInstallDircopyPreInstallResources, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyTemplate, copyTemplate, copyTemplate, getEntity, getResource, getResourceAsString, getVersion, kill, postLaunch, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, startequals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitisJmxEnabledgetEntity, isRunning, kill, rebind, restart, start, stopgetLocationpublic KafkaZooKeeperSshDriver(KafkaZooKeeperImpl entity, SshMachineLocation machine)
public java.lang.Integer getZookeeperPort()
getZookeeperPort in interface KafkaZooKeeperDriver