Package 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	Description
static final int	APPLICATION_STARTED_ORDER
protected static final String	DEFAULT_BOOTSTRAP_SERVERS
protected static final long	START_STAMP
static final String	XP_KAFKA_CONFIG

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

lastModified, name

Constructor Summary

Constructors

Constructor	Description
KafkaConfigServiceImpl()

Method Summary

Modifier and Type	Method	Description
Properties	getAdminProperties(String configName)	Returns the Kafka admin properties for a configuration.
int	getApplicationStartedOrder()	The component notification order for Component.start(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.
Set<String>	listConfigNames()	List the name of the registered Kafka configuration.
void	start(ComponentContext context)	Start the component.

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

activate, addRuntimeMessage, addRuntimeMessage, deactivate, getAdapter, getDescriptor, getDescriptors, getLastModified, getRegistry, register, registerContribution, registerExtension, setLastModified, setModifiedNow, setName, stop, unregister, unregisterContribution, unregisterExtension

Methods inherited from class java.lang.Object

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

Field Details

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

START_STAMP

protected static final long START_STAMP

Constructor Details

KafkaConfigServiceImpl

public KafkaConfigServiceImpl()

Method Details

getApplicationStartedOrder

public int getApplicationStartedOrder()

Description copied from interface: Component

The component notification order for Component.start(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

start

public void start(ComponentContext context)

Description copied from interface: Component

Start the component. This method is called after all the components were resolved and activated

Specified by:

start in interface Component

Overrides:

start in class DefaultComponent

listConfigNames

public Set<String> listConfigNames()

Description copied from interface: KafkaConfigService

List the name of the registered Kafka configuration.

Specified by:

listConfigNames 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

getAdminProperties

public Properties getAdminProperties(String configName)

Description copied from interface: KafkaConfigService

Returns the Kafka admin properties for a configuration.

Specified by:

getAdminProperties in interface KafkaConfigService

getDescriptor

protected KafkaConfigDescriptor getDescriptor(String configName)