KafkaBrokerSshDriver (Apache Brooklyn)

java.lang.Object
- brooklyn.entity.basic.AbstractSoftwareProcessDriver
- - brooklyn.entity.basic.AbstractSoftwareProcessSshDriver
  - - brooklyn.entity.java.JavaSoftwareProcessSshDriver
    - - brooklyn.entity.messaging.kafka.AbstractfKafkaSshDriver
      - brooklyn.entity.messaging.kafka.KafkaBrokerSshDriver

All Implemented Interfaces:

NaiveScriptRunner, SoftwareProcessDriver, EntityDriver, JavaSoftwareProcessDriver, KafkaBrokerDriver
```
public class KafkaBrokerSshDriver
extends AbstractfKafkaSshDriver
implements KafkaBrokerDriver
```

- Field Summary
  - Fields inherited from class brooklyn.entity.java.JavaSoftwareProcessSshDriver
    KEY_VAL_OPT_PREFIXES, MUTUALLY_EXCLUSIVE_OPTS
  - Fields inherited from class brooklyn.entity.basic.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
  
  KafkaBrokerSshDriver(KafkaBrokerImpl entity, SshMachineLocation machine)
- Method Summary
  
  Methods
  Modifier and Type Method and Description
  
  java.lang.Integer getKafkaPort()
  
  java.util.Map<java.lang.String,java.lang.String> getShellEnvironment()
  Use RMI agent to provide JMX.
  - Methods inherited from class brooklyn.entity.messaging.kafka.AbstractfKafkaSshDriver
    customize, getPidFile, install, isRunning, launch, preInstall, stop
  - Methods inherited from class brooklyn.entity.java.JavaSoftwareProcessSshDriver
    checkJavaHostnameBug, copyRuntimeResources, getJavaOpts, getJmxContext, getJmxPort, getRmiRegistryPort, installJava, installJmxSupport, isJmxEnabled, isJmxSslEnabled, setup
  - Methods inherited from class brooklyn.entity.basic.AbstractSoftwareProcessSshDriver
    checkNoHostnameBug, copyInstallResources, copyResource, copyResource, execute, execute, execute, getAddress, getExpandedInstallDir, getHostname, getInstallDir, getLocation, getMachine, getPortsUsed, getRunDir, getSubnetAddress, getSubnetHostname, runPostInstallCommand, runPostLaunchCommand, runPreInstallCommand, runPreLaunchCommand, setExpandedInstallDir
  - Methods inherited from class brooklyn.entity.basic.AbstractSoftwareProcessDriver
    copyPreInstallResources, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyResource, copyTemplate, copyTemplate, copyTemplate, getEntity, getResource, getResourceAsString, getVersion, kill, postLaunch, processTemplate, processTemplate, processTemplate, processTemplate, processTemplateContents, processTemplateContents, rebind, restart, start
  - Methods inherited from class java.lang.Object
    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  - Methods inherited from interface brooklyn.entity.java.JavaSoftwareProcessDriver
    isJmxEnabled
  - Methods inherited from interface brooklyn.entity.basic.SoftwareProcessDriver
    getEntity, isRunning, kill, rebind, restart, start, stop
  - Methods inherited from interface brooklyn.entity.drivers.EntityDriver
    getLocation

Constructors
Constructor and Description
`KafkaBrokerSshDriver(KafkaBrokerImpl entity, SshMachineLocation machine)`

Methods
Modifier and Type	Method and Description
`java.lang.Integer`	`getKafkaPort()`
`java.util.Map<java.lang.String,java.lang.String>`	`getShellEnvironment()` Use RMI agent to provide JMX.

- Constructor Detail
  - KafkaBrokerSshDriver
```
public KafkaBrokerSshDriver(KafkaBrokerImpl entity,
                    SshMachineLocation machine)
```
- Method Detail
  - getKafkaPort
```
public java.lang.Integer getKafkaPort()
```
    Specified by:
    
    getKafkaPort in interface KafkaBrokerDriver
  - getShellEnvironment
```
public java.util.Map<java.lang.String,java.lang.String> getShellEnvironment()
```
    Description copied from class: AbstractfKafkaSshDriver
    
    Use RMI agent to provide JMX.
    
    Overrides:
    
    getShellEnvironment in class AbstractfKafkaSshDriver
    
    See Also:
    SoftwareProcess.SHELL_ENVIRONMENT

Class KafkaBrokerSshDriver

Field Summary

Fields inherited from class brooklyn.entity.java.JavaSoftwareProcessSshDriver

Fields inherited from class brooklyn.entity.basic.AbstractSoftwareProcessSshDriver

Constructor Summary

Method Summary

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

Methods inherited from class brooklyn.entity.java.JavaSoftwareProcessSshDriver

Methods inherited from class brooklyn.entity.basic.AbstractSoftwareProcessSshDriver

Methods inherited from class brooklyn.entity.basic.AbstractSoftwareProcessDriver

Methods inherited from class java.lang.Object

Methods inherited from interface brooklyn.entity.java.JavaSoftwareProcessDriver

Methods inherited from interface brooklyn.entity.basic.SoftwareProcessDriver

Methods inherited from interface brooklyn.entity.drivers.EntityDriver

Constructor Detail

KafkaBrokerSshDriver

Method Detail

getKafkaPort

getShellEnvironment