|
Brooklyn | |||||||
FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectbrooklyn.entity.basic.AbstractEntity
brooklyn.entity.basic.SoftwareProcessImpl
brooklyn.entity.messaging.kafka.KafkaBrokerImpl
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)
|
Constructor Detail |
---|
public KafkaBrokerImpl()
Method Detail |
---|
connectServiceUpIsRunning(); protected void connectSensors()
public KafkaTopic createTopic(java.util.Map properties)
super.disconnectSensors(); public void disconnectSensors()
public Integer getBrokerId() { return getAttribute(BROKER_ID); } public java.lang.Integer getBrokerId()
public Class> getDriverInterface() { public java.lang.Class getDriverInterface()
public Integer getKafkaPort() { return getAttribute(KAFKA_PORT); } public java.lang.Integer getKafkaPort()
public Zookeeper getZookeeper() { return getConfig(ZOOKEEPER); } public Zookeeper getZookeeper()
@Override public void init()
Zookeeper zookeeper = getZookeeper(); public void setBrokerUrl()
return super.toStringHelper() protected ToStringHelper toStringHelper()
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.