Overview  Package   Class  Deprecated  Index  Help 
Brooklyn
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | METHOD DETAIL: FIELD | METHOD

brooklyn.entity.messaging.kafka
[Java] Interface KafkaCluster

brooklyn.entity.trait.Resizable
  brooklyn.entity.Entity
      brooklyn.entity.Group
          brooklyn.entity.trait.Startable
              brooklyn.entity.messaging.kafka.KafkaCluster
                  brooklyn.entity.rebind.Rebindable
All Superinterfaces:
Resizable, Entity, Group, Startable, Rebindable
@SuppressWarnings({ "unchecked", "rawtypes" })
@Catalog(name="Kafka", description="Apache Kafka is a distributed publish-subscribe messaging system")
@ImplementedBy(KafkaClusterImpl.class)
public interface KafkaCluster
extends Entity, Group, Resizable, Startable

Provides Kafka cluster functionality through a group of KafkaBroker controlled by a single KafkaZookeeper entity.

You can customise the Kafka zookeeper and brokers by supplying EntitySpec 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:

The Group and Resizable interface methods are delegated to the broker cluster, so calling Resizable#resize(Integer)#resize(Integer) will change the number of brokers.

Field Summary
BasicAttributeSensorAndConfigKey BROKER_SPEC

Spec for Kafka broker entities to be created.
AttributeSensor CLUSTER

Underlying Kafka broker cluster.
ConfigKey INITIAL_SIZE

ConfigKey START_TIMEOUT

BasicAttributeSensorAndConfigKey ZOOKEEPER

Zookeeper for the cluster.

BasicAttributeSensorAndConfigKey ZOOKEEPER_SPEC

Spec for creating the default Kafka zookeeper entity.
 
Fields inherited from interface Resizable
RESIZE
 
Fields inherited from interface Startable
RESTART, SERVICE_UP, START, STOP
 
Method Summary
DynamicCluster getCluster()

Zookeeper getZookeeper()

 
Methods inherited from interface Resizable
getCurrentSize, resize
 
Methods inherited from interface Entity
addChild, addChild, addEnricher, addGroup, addOwnedChild, addPolicy, clearOwner, clearParent, getApplication, getApplicationId, getAttribute, getChildren, getConfig, getDisplayName, getEnrichers, getEntityType, getGroups, getId, getLocations, getOwnedChildren, getOwner, getParent, getPolicies, getRebindSupport, invoke, removeChild, removeEnricher, removeOwnedChild, removePolicy, setOwner, setParent
 
Methods inherited from interface Group
addMember, getCurrentSize, getMembers, hasMember, removeMember
 
Methods inherited from interface Startable
restart, start, stop
 

Field Detail

BROKER_SPEC

@SetFromFlag("brokerSpec")
public BasicAttributeSensorAndConfigKey BROKER_SPEC
Spec for Kafka broker entities to be created.

CLUSTER

public AttributeSensor CLUSTER
Underlying Kafka broker cluster.

INITIAL_SIZE

@SetFromFlag("initialSize")
public ConfigKey INITIAL_SIZE

START_TIMEOUT

@SetFromFlag("startTimeout")
public ConfigKey START_TIMEOUT

ZOOKEEPER

@SetFromFlag("zookeeper")
public BasicAttributeSensorAndConfigKey ZOOKEEPER
Zookeeper for the cluster. If null a default be will created.

ZOOKEEPER_SPEC

@SetFromFlag("zookeeperSpec")
public BasicAttributeSensorAndConfigKey ZOOKEEPER_SPEC
Spec for creating the default Kafka zookeeper entity.

 
Method Detail

getCluster

public DynamicCluster getCluster()

getZookeeper

public Zookeeper getZookeeper()

 

Brooklyn Multi-Cloud Application Management Platform
brooklyncentral.github.com. Apache License. © 2012.