org.nuxeo.runtime.kafka

Class KafkaConfigServiceImpl

java.lang.Object

org.nuxeo.runtime.model.DefaultComponent

org.nuxeo.runtime.kafka.KafkaConfigServiceImpl

All Implemented Interfaces:

KafkaConfigService, Adaptable, Component, Extensible, TimestampedService

public class KafkaConfigServiceImpl
extends DefaultComponent
implements KafkaConfigService

Field Summary

Fields

Modifier and Type	Field and Description
static int	APPLICATION_STARTED_ORDER
protected Map<String,KafkaConfigDescriptor>	configs
static String	KAFKA_CONFIG_XP

Fields inherited from class org.nuxeo.runtime.model.DefaultComponent

lastModified

Constructor Summary

Constructors

Constructor and Description
KafkaConfigServiceImpl()

Method Summary

Modifier and Type	Method and Description
void	activate(ComponentContext context) Activates the component.
protected void	checkConfigName(String configName)
void	deactivate(ComponentContext context) Deactivates the component.
int	getApplicationStartedOrder() The component notification order for Component.applicationStarted(org.nuxeo.runtime.model.ComponentContext).
Properties	getConsumerProperties(String configName) Returns the kafka consumer properties for a configuration.
Properties	getProducerProperties(String configName) Returns the Kafka producer properties for a configuration.
String	getTopicPrefix(String configName) Returns the topic prefix to use for a configuration.
String	getZkServers(String configName) Returns the Zookeeper servers for a configuration.
Set<String>	listConfigNames() List the name of the registered Kafka configuration.
void	registerContribution(Object contribution, String extensionPoint, ComponentInstance contributor)

Methods inherited from class org.nuxeo.runtime.model.DefaultComponent

getAdapter, getLastModified, registerExtension, setLastModified, setModifiedNow, start, stop, unregisterContribution, unregisterExtension

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.nuxeo.runtime.model.Component

applicationStarted

Field Detail

KAFKA_CONFIG_XP

public static final String KAFKA_CONFIG_XP

See Also:

Constant Field Values

APPLICATION_STARTED_ORDER

public static final int APPLICATION_STARTED_ORDER

See Also:

Constant Field Values

configs

protected final Map<String,KafkaConfigDescriptor> configs

Constructor Detail

KafkaConfigServiceImpl

public KafkaConfigServiceImpl()

Method Detail

registerContribution

public void registerContribution(Object contribution,
                                 String extensionPoint,
                                 ComponentInstance contributor)

Overrides:

registerContribution in class DefaultComponent

getApplicationStartedOrder

public int getApplicationStartedOrder()

Description copied from interface: Component

The component notification order for Component.applicationStarted(org.nuxeo.runtime.model.ComponentContext).

Components are notified in increasing order. Order 1000 is the default order for components that don't care. Order 100 is the repository initialization.

Specified by:

getApplicationStartedOrder in interface Component

Returns:

the order, 1000 by default

deactivate

public void deactivate(ComponentContext context)

Description copied from interface: Component

Deactivates the component.

This method is called by the runtime when a component is deactivated.

Specified by:

deactivate in interface Component

Overrides:

deactivate in class DefaultComponent

Parameters:

context - the runtime context

activate

public void activate(ComponentContext context)

Description copied from interface: Component

Activates the component.

This method is called by the runtime when a component is activated.

Specified by:

activate in interface Component

Overrides:

activate in class DefaultComponent

Parameters:

context - the runtime context

listConfigNames

public Set<String> listConfigNames()

Description copied from interface: KafkaConfigService

List the name of the registered Kafka configuration.

Specified by:

listConfigNames in interface KafkaConfigService

getZkServers

public String getZkServers(String configName)

Description copied from interface: KafkaConfigService

Returns the Zookeeper servers for a configuration.

Specified by:

getZkServers in interface KafkaConfigService

checkConfigName

protected void checkConfigName(String configName)

getProducerProperties

public Properties getProducerProperties(String configName)

Description copied from interface: KafkaConfigService

Returns the Kafka producer properties for a configuration.

Specified by:

getProducerProperties in interface KafkaConfigService

getConsumerProperties

public Properties getConsumerProperties(String configName)

Description copied from interface: KafkaConfigService

Returns the kafka consumer properties for a configuration.

Specified by:

getConsumerProperties in interface KafkaConfigService

getTopicPrefix

public String getTopicPrefix(String configName)

Description copied from interface: KafkaConfigService

Returns the topic prefix to use for a configuration.

Specified by:

getTopicPrefix in interface KafkaConfigService