public class KafkaConfigServiceImpl extends DefaultComponent implements KafkaConfigService
Modifier and Type | Field and Description |
---|---|
static int |
APPLICATION_STARTED_ORDER |
protected static String |
DEFAULT_BOOTSTRAP_SERVERS |
static String |
XP_KAFKA_CONFIG |
lastModified, name
Constructor and Description |
---|
KafkaConfigServiceImpl() |
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.
|
activate, deactivate, getAdapter, getDescriptor, getDescriptors, getLastModified, getRegistry, register, registerContribution, registerExtension, setLastModified, setModifiedNow, setName, start, stop, unregister, unregisterContribution, unregisterExtension
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
applicationStarted
public static final String XP_KAFKA_CONFIG
public static final int APPLICATION_STARTED_ORDER
protected static final String DEFAULT_BOOTSTRAP_SERVERS
public KafkaConfigServiceImpl()
public int getApplicationStartedOrder()
Component
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.
getApplicationStartedOrder
in interface Component
public Set<String> listConfigNames()
KafkaConfigService
listConfigNames
in interface KafkaConfigService
@Deprecated public String getZkServers(String configName)
KafkaConfigService
getZkServers
in interface KafkaConfigService
public Properties getProducerProperties(String configName)
KafkaConfigService
getProducerProperties
in interface KafkaConfigService
public Properties getConsumerProperties(String configName)
KafkaConfigService
getConsumerProperties
in interface KafkaConfigService
public String getTopicPrefix(String configName)
KafkaConfigService
getTopicPrefix
in interface KafkaConfigService
protected KafkaConfigDescriptor getDescriptor(String configName)
Copyright © 2019 Nuxeo. All rights reserved.