org.apache.brooklyn.entity.messaging.kafka

Interface KafkaZooKeeper

All Superinterfaces:

BrooklynObject, Configurable, Entity, Identifiable, Kafka, SoftwareProcess, Startable, ZooKeeperNode

All Known Implementing Classes:

KafkaZooKeeperImpl

public interface KafkaZooKeeper
extends ZooKeeperNode, Kafka

An Entity that represents a single Kafka zookeeper instance.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.brooklyn.entity.software.base.SoftwareProcess

SoftwareProcess.ChildStartableMode, SoftwareProcess.RestartSoftwareParameters, SoftwareProcess.StopSoftwareParameters

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.entity.Entity

Entity.AdjunctSupport<T extends EntityAdjunct>, Entity.EnricherSupport, Entity.GroupSupport, Entity.PolicySupport, Entity.SensorSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.objs.BrooklynObject

BrooklynObject.RelationSupport<T extends BrooklynObject>, BrooklynObject.SubscriptionSupport, BrooklynObject.TagSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.api.objs.Configurable

Configurable.ConfigurationSupport

Nested classes/interfaces inherited from interface org.apache.brooklyn.core.entity.trait.Startable

Startable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBody

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigKey<java.lang.String>	ARCHIVE_DIRECTORY_NAME_FORMAT
static BasicAttributeSensorAndConfigKey<java.lang.String>	DOWNLOAD_URL The Kafka version, not the Zookeeper version.
static ConfigKey<java.lang.String>	KAFKA_ZOOKEEPER_CONFIG_TEMPLATE Location of the kafka configuration file template to be copied to the server.
static ConfigKey<Duration>	START_TIMEOUT
static ConfigKey<java.lang.String>	SUGGESTED_VERSION The Kafka version, not the Zookeeper version.

Fields inherited from interface org.apache.brooklyn.entity.zookeeper.ZooKeeperNode

MY_ID, OUTSTANDING_REQUESTS, PACKETS_RECEIVED, PACKETS_SENT, ZOOKEEPER_CONFIG_TEMPLATE, ZOOKEEPER_ELECTION_PORT, ZOOKEEPER_ENDPOINT, ZOOKEEPER_LEADER_PORT, ZOOKEEPER_PORT

Fields inherited from interface org.apache.brooklyn.entity.software.base.SoftwareProcess

ADD_OPEN_INBOUND_PORTS_EFFECTOR, ADDRESS, CHILDREN_STARTABLE_MODE, CUSTOMIZE_FILES, CUSTOMIZE_LATCH, CUSTOMIZE_TEMPLATES, DONT_REQUIRE_TTY_FOR_SUDO, DOWNLOAD_ADDON_URLS, ENTITY_STARTED, EXPANDED_INSTALL_DIR, HOSTNAME, INBOUND_PORTS_AUTO_INFER, INBOUND_PORTS_CONFIG_REGEX, INSTALL_DIR, INSTALL_FILES, INSTALL_LATCH, INSTALL_RESOURCES_LATCH, INSTALL_TEMPLATES, INSTALL_UNIQUE_LABEL, LAUNCH_LATCH, LIFECYCLE_EFFECTOR_TASKS, MAXIMUM_REBIND_SENSOR_CONNECT_DELAY, OPEN_IPTABLES, PID_FILE, POST_CUSTOMIZE_COMMAND, POST_INSTALL_COMMAND, POST_LAUNCH_COMMAND, PRE_CUSTOMIZE_COMMAND, PRE_INSTALL_COMMAND, PRE_INSTALL_FILES, PRE_INSTALL_TEMPLATES, PRE_LAUNCH_COMMAND, PROVISIONING_LOCATION, PROVISIONING_PROPERTIES, REQUIRED_OPEN_LOGIN_PORTS, RETRIEVE_USAGE_METRICS, RUN_DIR, RUNTIME_FILES, RUNTIME_RESOURCES_LATCH, RUNTIME_TEMPLATES, SERVICE_PROCESS_IS_RUNNING, SERVICE_PROCESS_IS_RUNNING_POLL_PERIOD, SERVICE_STATE_ACTUAL, SERVICE_STATE_EXPECTED, SETUP_LATCH, SHELL_ENVIRONMENT, SKIP_ENTITY_START_IF_RUNNING, SKIP_INSTALLATION, START_LATCH, STOP_IPTABLES, STOP_LATCH, SUBNET_ADDRESS, SUBNET_HOSTNAME, TEMPLATE_SUBSTITUTIONS

Fields inherited from interface org.apache.brooklyn.core.entity.trait.Startable

RESTART, SERVICE_UP, START, STOP

Method Summary

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

Methods inherited from interface org.apache.brooklyn.entity.zookeeper.ZooKeeperNode

getHostname, getZookeeperPort

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

populateServiceNotUpDiagnostics

Methods inherited from interface org.apache.brooklyn.api.entity.Entity

addChild, addChild, addFeed, clearParent, enrichers, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getCreationTime, getDisplayName, getEntityType, getIconUrl, getId, getLocations, getParent, groups, invoke, policies, relations, removeChild, sensors, setDisplayName, setParent

Methods inherited from interface org.apache.brooklyn.api.objs.BrooklynObject

getCatalogItemId, getCatalogItemIdSearchPath, subscriptions, tags

Methods inherited from interface org.apache.brooklyn.api.objs.Configurable

config, getConfig

Methods inherited from interface org.apache.brooklyn.core.entity.trait.Startable

restart, start, stop

Field Detail

START_TIMEOUT

static final ConfigKey<Duration> START_TIMEOUT

SUGGESTED_VERSION

static final ConfigKey<java.lang.String> SUGGESTED_VERSION

The Kafka version, not the Zookeeper version.

DOWNLOAD_URL

static final BasicAttributeSensorAndConfigKey<java.lang.String> DOWNLOAD_URL

The Kafka version, not the Zookeeper version.

KAFKA_ZOOKEEPER_CONFIG_TEMPLATE

static final ConfigKey<java.lang.String> KAFKA_ZOOKEEPER_CONFIG_TEMPLATE

Location of the kafka configuration file template to be copied to the server.

ARCHIVE_DIRECTORY_NAME_FORMAT

static final ConfigKey<java.lang.String> ARCHIVE_DIRECTORY_NAME_FORMAT

Method Detail

createTopic

void createTopic(java.lang.String topic)