org.apache.brooklyn.entity.messaging.kafka

Interface KafkaCluster

All Superinterfaces:

BrooklynObject, Configurable, Entity, Group, Identifiable, Resizable, Startable

All Known Implementing Classes:

KafkaClusterImpl

public interface KafkaCluster
extends Entity, Startable, Resizable, Group

Provides Kafka cluster functionality through a group of brokers controlled by a single zookeeper entity.

You can customise the Kafka zookeeper and brokers by supplying entity specifications to be used when creating them. An existing Zookeeper entity may also be provided instead of the Kafka zookeeper.

The contents of this entity are:

• a DynamicCluster of KafkaBrokers
• a KafkaZookeeper or Zookeeper
• a Policy to resize the broker cluster

The group and Resizable interface methods are delegated to the broker cluster, so calling resize will change the number of brokers.

Nested Class Summary

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

Startable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBody

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

Resizable.InsufficientCapacityException

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

Field Summary

Fields

Modifier and Type	Field and Description
static BasicAttributeSensorAndConfigKey<EntitySpec<KafkaBroker>>	BROKER_SPEC Spec for Kafka broker entities to be created.
static AttributeSensor<DynamicCluster>	CLUSTER Underlying Kafka broker cluster.
static ConfigKey<java.lang.Integer>	INITIAL_SIZE
static ConfigKey<Duration>	START_TIMEOUT
static BasicAttributeSensorAndConfigKey<ZooKeeperNode>	ZOOKEEPER Zookeeper for the cluster.
static BasicAttributeSensorAndConfigKey<EntitySpec<KafkaZooKeeper>>	ZOOKEEPER_SPEC Spec for creating the default Kafka zookeeper entity.

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

RESTART, SERVICE_UP, START, STOP

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

RESIZE

Method Summary

Modifier and Type	Method and Description
DynamicCluster	getCluster()
ZooKeeperNode	getZooKeeper()

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

restart, start, stop

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

getCurrentSize, resize

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

addChild, addChild, addMember, addMemberChild, addMemberChild, getCurrentSize, getMembers, hasMember, removeMember

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

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

Field Detail

START_TIMEOUT

static final ConfigKey<Duration> START_TIMEOUT

INITIAL_SIZE

static final ConfigKey<java.lang.Integer> INITIAL_SIZE

ZOOKEEPER

static final BasicAttributeSensorAndConfigKey<ZooKeeperNode> ZOOKEEPER

Zookeeper for the cluster. If null a default be will created.

ZOOKEEPER_SPEC

static final BasicAttributeSensorAndConfigKey<EntitySpec<KafkaZooKeeper>> ZOOKEEPER_SPEC

Spec for creating the default Kafka zookeeper entity.

BROKER_SPEC

static final BasicAttributeSensorAndConfigKey<EntitySpec<KafkaBroker>> BROKER_SPEC

Spec for Kafka broker entities to be created.

CLUSTER

static final AttributeSensor<DynamicCluster> CLUSTER

Underlying Kafka broker cluster.

Method Detail

getZooKeeper

ZooKeeperNode getZooKeeper()

getCluster

DynamicCluster getCluster()