org.apache.brooklyn.entity.messaging.kafka

Class KafkaZooKeeperSshDriver

java.lang.Object

org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessDriver

org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessSshDriver

org.apache.brooklyn.entity.java.JavaSoftwareProcessSshDriver

org.apache.brooklyn.entity.messaging.kafka.AbstractfKafkaSshDriver

org.apache.brooklyn.entity.messaging.kafka.KafkaZooKeeperSshDriver

All Implemented Interfaces:

EntityDriver, JavaSoftwareProcessDriver, KafkaZooKeeperDriver, NaiveScriptRunner, SoftwareProcessDriver

public class KafkaZooKeeperSshDriver
extends AbstractfKafkaSshDriver
implements KafkaZooKeeperDriver

Field Summary

Fields inherited from class org.apache.brooklyn.entity.java.JavaSoftwareProcessSshDriver

KEY_VAL_OPT_PREFIXES, MUTUALLY_EXCLUSIVE_OPTS

Fields inherited from class org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessSshDriver

CHECK_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 Summary

Constructors

Constructor and Description
KafkaZooKeeperSshDriver(KafkaZooKeeperImpl entity, SshMachineLocation machine)

Method Summary

Modifier and Type	Method and Description
void	createTopic(java.lang.String topic)
java.lang.Integer	getZookeeperPort()

Methods inherited from class org.apache.brooklyn.entity.messaging.kafka.AbstractfKafkaSshDriver

customize, getPidFile, getShellEnvironment, install, isRunning, launch, stop

Methods inherited from class org.apache.brooklyn.entity.java.JavaSoftwareProcessSshDriver

checkJavaHostnameBug, copyRuntimeResources, getJavaOpts, getJmxContext, getJmxPort, getRmiRegistryPort, installJava, installJmxSupport, isJmxEnabled, isJmxSslEnabled, setup

Methods inherited from class org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessSshDriver

checkNoHostnameBug, copyCustomizeResources, copyInstallResources, copyPreInstallResources, copyResource, copyResource, execute, execute, execute, getAddress, getHostname, getLocation, getMachine, getPortsUsed, getSubnetAddress, getSubnetHostname, prepare, runPostCustomizeCommand, runPostInstallCommand, runPostLaunchCommand, runPreCustomizeCommand, runPreInstallCommand, runPreLaunchCommand

Methods inherited from class org.apache.brooklyn.entity.software.base.AbstractSoftwareProcessDriver

copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyTemplate, copyTemplate, copyTemplate, getArchiveNameFormat, getEntity, getExpandedInstallDir, getInstallDir, getResource, getResourceAsString, getRunDir, getVersion, kill, postLaunch, preInstall, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, setExpandedInstallDir, start

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.brooklyn.entity.java.JavaSoftwareProcessDriver

isJmxEnabled

Methods inherited from interface org.apache.brooklyn.entity.software.base.SoftwareProcessDriver

getEntity, isRunning, kill, rebind, restart, start, stop

Methods inherited from interface org.apache.brooklyn.api.entity.drivers.EntityDriver

getLocation

Constructor Detail

KafkaZooKeeperSshDriver

public KafkaZooKeeperSshDriver(KafkaZooKeeperImpl entity,
                               SshMachineLocation machine)

Method Detail

getZookeeperPort

public java.lang.Integer getZookeeperPort()

Specified by:

getZookeeperPort in interface KafkaZooKeeperDriver

createTopic

public void createTopic(java.lang.String topic)

Specified by:

createTopic in interface KafkaZooKeeperDriver