Overview  Package   Class  Deprecated  Index  Help 
Brooklyn
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

brooklyn.entity.messaging.kafka
[Java] Class KafkaBrokerImpl

java.lang.Object
  brooklyn.entity.basic.AbstractEntity
      brooklyn.entity.basic.SoftwareProcessImpl
          brooklyn.entity.messaging.kafka.KafkaBrokerImpl
All Implemented Interfaces:
KafkaBroker, MessageBroker
public class KafkaBrokerImpl
extends SoftwareProcessImpl

An Entity that represents a single Kafka broker instance.

Field Summary
 
Fields inherited from class SoftwareProcessImpl
connectedSensors
 
Fields inherited from class AbstractEntity
EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, LOG, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED, _subscriptionTracker, managementSupport, tempWorkings
 
Constructor Summary
KafkaBrokerImpl()

 
Method Summary
protected void connectSensors()

KafkaTopic createTopic(java.util.Map properties)

void disconnectSensors()

java.lang.Integer getBrokerId()

java.lang.Class getDriverInterface()

java.lang.Integer getKafkaPort()

Zookeeper getZookeeper()

void init()

void setBrokerUrl()

Use the zookeeper details if available, otherwise use our own host and port.
protected ToStringHelper toStringHelper()

void waitForServiceUp(long duration, java.util.concurrent.TimeUnit units)

 
Methods inherited from class SoftwareProcessImpl
callRebindHooks, callStartHooks, checkModifiable, connectSensors, connectServiceUpIsRunning, disconnectSensors, disconnectServiceUpIsRunning, doInitDriver, doRestart, doStart, doStop, getDriver, getLocalHostname, getMachineOrNull, getProvisioningFlags, getProvisioningLocation, getRequiredOpenPorts, newDriver, obtainProvisioningFlags, onManagementStarted, onManagementStarting, postDriverStart, postRebind, postStart, preStart, preStop, rebind, restart, setProvisioningLocation, start, startInLocation, startInLocation, startInLocation, startInLocation, stop, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUp, waitForServiceUp
 
Methods inherited from class AbstractEntity
addChild, addChild, addEnricher, addGroup, addLocations, addPolicy, clearLocations, clearParent, configure, configure, configure, configure, configure, configure, destroy, emit, emitInternal, equals, finalize, firstLocation, getAllAttributes, getAllConfig, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getConfig, getConfig, getConfig, getConfig, getConfigMap, getCreationTime, getDisplayName, getEffector, getEnrichers, getEntityManager, getEntityType, getEntityTypeName, getExecutionContext, getGroups, getIconUrl, getId, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getSubscriptionTracker, hashCode, init, invalidateReferences, invoke, invoke, invoke, isLegacyConstruction, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStarted, onManagementStarting, onManagementStopped, refreshInheritedConfig, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeLocations, removePolicy, setApplication, setAttribute, setAttribute, setAttributeWithoutPublishing, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setConfigIfValNonNull, setConfigIfValNonNull, setDisplayName, setManagementContext, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toMetadataRecord, toString, toStringHelper, unsubscribe, unsubscribe
 

Constructor Detail

KafkaBrokerImpl

public KafkaBrokerImpl()

 
Method Detail

connectSensors

connectServiceUpIsRunning();
protected void connectSensors()

createTopic

public KafkaTopic createTopic(java.util.Map properties)

disconnectSensors

super.disconnectSensors();
public void disconnectSensors()

getBrokerId

public Integer getBrokerId() { return getAttribute(BROKER_ID); }
public java.lang.Integer getBrokerId()

getDriverInterface

public Class getDriverInterface() {
public java.lang.Class getDriverInterface()

getKafkaPort

public Integer getKafkaPort() { return getAttribute(KAFKA_PORT); }
public java.lang.Integer getKafkaPort()

getZookeeper

public Zookeeper getZookeeper() { return getConfig(ZOOKEEPER); }
public Zookeeper getZookeeper()

init

@Override
public void init()

setBrokerUrl

Zookeeper zookeeper = getZookeeper();
public void setBrokerUrl()
Use the zookeeper details if available, otherwise use our own host and port.

toStringHelper

return super.toStringHelper()
protected ToStringHelper toStringHelper()

waitForServiceUp

public void waitForServiceUp(long duration, TimeUnit units) {
public void waitForServiceUp(long duration, java.util.concurrent.TimeUnit units)

 

Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.