public interface KafkaCluster extends Entity, Startable, Resizable, Group
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:
DynamicCluster of KafkaBrokers
KafkaZookeeper or Zookeeper
Policy to resize the broker cluster
group and Resizable interface methods are delegated to the broker cluster, so calling
resize will change the number of brokers.Startable.RestartEffectorBody, Startable.StartEffectorBody, Startable.StopEffectorBodyBrooklynObject.TagSupportConfigurable.ConfigurationSupport| 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.
|
RESTART, SERVICE_UP, START, STOP| Modifier and Type | Method and Description |
|---|---|
DynamicCluster |
getCluster() |
ZooKeeperNode |
getZooKeeper() |
getCurrentSize, resizeaddChild, addChild, addMember, addMemberChild, addMemberChild, getCurrentSize, getMembers, hasMember, removeMemberaddEnricher, 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, setConfigstatic final ConfigKey<java.lang.Integer> INITIAL_SIZE
static final BasicAttributeSensorAndConfigKey<ZooKeeperNode> ZOOKEEPER
static final BasicAttributeSensorAndConfigKey<EntitySpec<KafkaZooKeeper>> ZOOKEEPER_SPEC
static final BasicAttributeSensorAndConfigKey<EntitySpec<KafkaBroker>> BROKER_SPEC
static final AttributeSensor<DynamicCluster> CLUSTER
ZooKeeperNode getZooKeeper()
DynamicCluster getCluster()