public class KafkaBrokerImpl extends SoftwareProcessImpl implements MessageBroker, KafkaBroker
Entity that represents a single Kafka broker instance.SoftwareProcess.ChildStartableMode, SoftwareProcess.RestartSoftwareParameters, SoftwareProcess.StopSoftwareParametersStartable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBodyBrooklynObject.TagSupportConfigurable.ConfigurationSupportUsesJmx.JmxAgentModesEntityInternal.FeedSupportBrooklynObjectInternal.ConfigurationSupportInternalCHILD_ADDED, CHILD_REMOVED, EFFECTOR_ADDED, EFFECTOR_CHANGED, EFFECTOR_REMOVED, LOCATION_ADDED, LOCATION_REMOVED, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVEDBROKER_ID, BYTES_RECEIVED, BYTES_SENT, FETCH_REQUEST_COUNT, INTERNAL_JMX_PORT, KAFKA_BROKER_CONFIG_TEMPLATE, KAFKA_PORT, MAX_FETCH_TIME, MAX_PRODUCE_TIME, PRODUCE_REQUEST_COUNT, START_TIMEOUT, SUGGESTED_VERSION, TOTAL_FETCH_TIME, TOTAL_PRODUCE_TIME, ZOOKEEPERADDRESS, CHILDREN_STARTABLE_MODE, CUSTOMIZE_LATCH, DOWNLOAD_ADDON_URLS, DOWNLOAD_URL, ENTITY_STARTED, EXPANDED_INSTALL_DIR, HOSTNAME, INSTALL_DIR, INSTALL_FILES, INSTALL_LATCH, INSTALL_RESOURCES_LATCH, INSTALL_TEMPLATES, INSTALL_UNIQUE_LABEL, LAUNCH_LATCH, MAXIMUM_REBIND_SENSOR_CONNECT_DELAY, PID_FILE, POST_INSTALL_COMMAND, POST_LAUNCH_COMMAND, PRE_INSTALL_COMMAND, PRE_INSTALL_FILES, PRE_INSTALL_TEMPLATES, PRE_LAUNCH_COMMAND, PROVISIONING_LOCATION, PROVISIONING_PROPERTIES, REQUIRED_OPEN_LOGIN_PORTS, RUN_DIR, RUNTIME_FILES, RUNTIME_RESOURCES_LATCH, RUNTIME_TEMPLATES, SERVICE_PROCESS_IS_RUNNING, SERVICE_STATE_ACTUAL, SERVICE_STATE_EXPECTED, SETUP_LATCH, SHELL_ENVIRONMENT, SKIP_ENTITY_START_IF_RUNNING, SKIP_INSTALLATION, START_LATCH, SUBNET_ADDRESS, SUBNET_HOSTNAME, SUGGESTED_INSTALL_DIR, SUGGESTED_RUN_DIRRESTART, SERVICE_UP, START, STOPBROKER_URLDEFAULT_JMX_PORT, JMX_AGENT_LOCAL_PATH, JMX_AGENT_MODE, JMX_CONTEXT, JMX_PASSWORD, JMX_PORT, JMX_PORT_LEGACY, JMX_SSL_ACCESS_CERT, JMX_SSL_ACCESS_KEY, JMX_SSL_ENABLED, JMX_URL, JMX_USER, RMI_REGISTRY_PORT, USE_JMXCHECK_JAVA_HOSTNAME_BUG, JAVA_OPTS, JAVA_SYSPROPS, JAVA_VERSION_REQUIREDDOWNLOAD_URL| Constructor and Description |
|---|
KafkaBrokerImpl() |
| Modifier and Type | Method and Description |
|---|---|
KafkaTopic |
createTopic(java.util.Map<?,?> properties) |
void |
disconnectSensors()
For disconnecting from the running app.
|
java.lang.Integer |
getBrokerId() |
java.lang.Class<?> |
getDriverInterface() |
java.lang.Integer |
getKafkaPort() |
ZooKeeperNode |
getZookeeper() |
void |
init()
Default entity initialization, just calls
AbstractEntity.initEnrichers(). |
void |
setBrokerUrl()
Use the
zookeeper details if available, otherwise use our own host and port. |
void |
waitForServiceUp(long duration,
java.util.concurrent.TimeUnit units) |
checkModifiable, getDriver, getLocalHostname, onManagementStarted, onManagementStarting, rebind, restart, start, stop, waitForEntityStart, waitForServiceUp, waitForServiceUp, waitForServiceUpaddChild, addChild, addEnricher, addEnricher, addFeed, addGroup, addLocations, addPolicy, addPolicy, addTag, clearLocations, clearParent, config, configure, configure, configure, configure, configure, containsTag, destroy, emit, emitInternal, equals, feeds, firstLocation, getAllAttributes, getAllConfig, getAllConfigBag, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getConfig, getConfig, getConfig, getConfig, getConfigMap, getConfigRaw, getConfigRaw, getCreationTime, getDisplayName, getEffector, getEnrichers, getEntityType, getExecutionContext, getFeedSupport, getGroups, getIconUrl, getLocalConfigBag, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getTags, hashCode, invalidateReferences, invoke, invoke, invoke, modifyAttribute, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStopped, refreshInheritedConfig, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeGroup, removeLocations, removePolicy, removeTag, requestPersist, resetProxy, setAttribute, setAttribute, setAttributeWithoutPublishing, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setDisplayName, setManagementContext, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toMetadataRecord, toString, unsubscribe, unsubscribegetCatalogItemId, getId, getTagSupport, setCatalogItemId, tagsaddChild, addChild, addEnricher, addEnricher, addFeed, addGroup, addPolicy, addPolicy, addTag, clearParent, containsTag, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getConfig, getConfigRaw, getConfigRaw, getCreationTime, getDisplayName, getEnrichers, getEntityType, getGroups, getIconUrl, getId, getLocations, getParent, getPolicies, getTags, invoke, removeChild, removeEnricher, removeGroup, removePolicy, removeTag, setParentgetCatalogItemId, getTagSupport, tagsconfig, setConfigsetCatalogItemIdpublic void init()
AbstractEntityAbstractEntity.initEnrichers().init in class SoftwareProcessImplpublic java.lang.Integer getKafkaPort()
getKafkaPort in interface KafkaBrokerpublic java.lang.Integer getBrokerId()
getBrokerId in interface KafkaBrokerpublic ZooKeeperNode getZookeeper()
getZookeeper in interface KafkaBrokerpublic KafkaTopic createTopic(java.util.Map<?,?> properties)
public java.lang.Class<?> getDriverInterface()
getDriverInterface in interface DriverDependentEntitypublic void waitForServiceUp(long duration,
java.util.concurrent.TimeUnit units)
waitForServiceUp in class SoftwareProcessImplpublic void disconnectSensors()
SoftwareProcessImplpublic void setBrokerUrl()
zookeeper details if available, otherwise use our own host and port.setBrokerUrl in interface MessageBroker