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

brooklyn.entity.messaging.kafka
[Java] Class KafkaClusterImpl

java.lang.Object
  groovy.lang.GroovyObjectSupport
      brooklyn.entity.basic.AbstractEntity
          brooklyn.entity.messaging.kafka.KafkaClusterImpl
All Implemented Interfaces:
KafkaCluster
public class KafkaClusterImpl
extends AbstractEntity

Implementation of a Kafka cluster containing a KafkaZookeeper node and a group of KafkaBrokers.

Field Summary
static Logger log

 
Fields inherited from class AbstractEntity
LOG, POLICY_ADDED, POLICY_REMOVED, SENSOR_ADDED, SENSOR_REMOVED, _subscriptionTracker, attributesInternal, configsInternal, managementSupport, tempWorkings
 
Constructor Summary
KafkaClusterImpl()

KafkaClusterImpl(java.util.Map flags)

KafkaClusterImpl(Entity parent)

KafkaClusterImpl(java.util.Map flags, Entity parent)

 
Method Summary
boolean addMember(Entity member)

{@inheritDoc}
DynamicCluster getCluster()

java.lang.Integer getCurrentSize()

{@inheritDoc}
java.util.Collection getMembers()

{@inheritDoc}
Zookeeper getZookeeper()

boolean hasMember(Entity member)

{@inheritDoc}
void init()

boolean removeMember(Entity member)

{@inheritDoc}
java.lang.Integer resize(java.lang.Integer desiredSize)

{@inheritDoc}
void restart()

void start(java.util.Collection locations)

void stop()

 
Methods inherited from class AbstractEntity
addChild, addChild, addEnricher, addGroup, addLocations, addOwnedChild, addPolicy, assertNotYetOwned, clearOwner, clearParent, configure, configure, configure, configure, configure, createManagementSupport, destroy, emit, emitInternal, equals, finalize, firstLocation, getAllAttributes, getAllConfig, getApplication, getApplicationId, getAttribute, getAttributeByNameParts, getChildren, getChildrenReference, getConfig, getConfig, getConfig, getConfig, getConfigMap, getDisplayName, getEffector, getEnrichers, getEntityManager, getEntityType, getEntityTypeName, getExecutionContext, getGroups, getId, getLocations, getManagementContext, getManagementSupport, getMutableEntityType, getOwnedChildren, getOwnedChildrenReference, getOwner, getParent, getPolicies, getProxy, getProxyIfAvailable, getRebindSupport, getSubscriptionContext, getSubscriptionTracker, hasEverBeenManaged, hashCode, init, invalidateReferences, invoke, invoke, invokeFromJava, invokeMethod, isLegacyConstruction, onManagementBecomingMaster, onManagementNoLongerMaster, onManagementStarted, onManagementStarting, refreshInheritedConfig, refreshInheritedConfigOfChildren, removeAllEnrichers, removeAllPolicies, removeAttribute, removeChild, removeEnricher, removeLocations, removeOwnedChild, removePolicy, setApplication, setAttribute, setAttribute, setAttributeWithoutPublishing, setBeingManaged, setConfig, setConfig, setConfig, setConfig, setConfig, setConfig, setConfigEvenIfOwned, setConfigEvenIfOwned, setConfigIfValNonNull, setConfigIfValNonNull, setDisplayName, setManagementContext, setOwner, setParent, setProxy, subscribe, subscribeToChildren, subscribeToMembers, toString, toStringFieldsToInclude, toStringHelper, unsubscribe, unsubscribe
 
Methods inherited from class groovy.lang.GroovyObjectSupport
groovy.lang.GroovyObjectSupport#setProperty(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#getProperty(java.lang.String), groovy.lang.GroovyObjectSupport#getMetaClass(), groovy.lang.GroovyObjectSupport#setMetaClass(groovy.lang.MetaClass), groovy.lang.GroovyObjectSupport#invokeMethod(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#wait(), groovy.lang.GroovyObjectSupport#wait(long), groovy.lang.GroovyObjectSupport#wait(long, int), groovy.lang.GroovyObjectSupport#equals(java.lang.Object), groovy.lang.GroovyObjectSupport#toString(), groovy.lang.GroovyObjectSupport#hashCode(), groovy.lang.GroovyObjectSupport#getClass(), groovy.lang.GroovyObjectSupport#notify(), groovy.lang.GroovyObjectSupport#notifyAll()
 

Field Detail

log

public static final Logger log

 
Constructor Detail

KafkaClusterImpl

public KafkaClusterImpl()

KafkaClusterImpl

public KafkaClusterImpl(java.util.Map flags)

KafkaClusterImpl

public KafkaClusterImpl(Entity parent)

KafkaClusterImpl

public KafkaClusterImpl(java.util.Map flags, Entity parent)

 
Method Detail

addMember

@Override
public boolean addMember(Entity member)
{@inheritDoc}

getCluster

@Override
public DynamicCluster getCluster()

getCurrentSize

@Override
public java.lang.Integer getCurrentSize()
{@inheritDoc}

getMembers

@Override
public java.util.Collection getMembers()
{@inheritDoc}

getZookeeper

@Override
public Zookeeper getZookeeper()

hasMember

@Override
public boolean hasMember(Entity member)
{@inheritDoc}

init

@Override
public void init()

removeMember

@Override
public boolean removeMember(Entity member)
{@inheritDoc}

resize

@Override
public java.lang.Integer resize(java.lang.Integer desiredSize)
{@inheritDoc}

restart

@Override
public void restart()

start

@Override
public void start(java.util.Collection locations)

stop

@Override
public void stop()

 

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