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 static String	DEFAULT_BOOTSTRAP_SERVERS
static String	XP_KAFKA_CONFIG

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

lastModified, name

Constructor Summary

Constructors

Constructor and Description
KafkaConfigServiceImpl()

Method Summary

Modifier and Type	Method and Description
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.
protected KafkaConfigDescriptor	getDescriptor(String configName)
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) Deprecated.
Set<String>	listConfigNames() List the name of the registered Kafka configuration.

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

activate, deactivate, getAdapter, getDescriptor, getDescriptors, getLastModified, getRegistry, register, registerContribution, registerExtension, setLastModified, setModifiedNow, setName, start, stop, unregister, 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

XP_KAFKA_CONFIG

public static final String XP_KAFKA_CONFIG

See Also:

Constant Field Values

APPLICATION_STARTED_ORDER

public static final int APPLICATION_STARTED_ORDER

See Also:

Constant Field Values

DEFAULT_BOOTSTRAP_SERVERS

protected static final String DEFAULT_BOOTSTRAP_SERVERS

See Also:

Constant Field Values

Constructor Detail

KafkaConfigServiceImpl

public KafkaConfigServiceImpl()

Method Detail

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

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

@Deprecated
public String getZkServers(String configName)

Deprecated.

Description copied from interface: KafkaConfigService

Returns the Zookeeper servers for a configuration.

Specified by:

getZkServers in interface KafkaConfigService

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

getDescriptor

protected KafkaConfigDescriptor getDescriptor(String configName)