org.nuxeo.runtime.kafka

Interface KafkaConfigService

All Known Implementing Classes:

KafkaConfigServiceImpl

public interface KafkaConfigService

Service to collect kafka configurations.

Since:

9.3

Method Summary

Modifier and Type	Method and Description
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) Deprecated. since 10.2 NXP-24634: we don't want to depend anymore on Zookeeper
Set<String>	listConfigNames() List the name of the registered Kafka configuration.

Method Detail

listConfigNames

Set<String> listConfigNames()

List the name of the registered Kafka configuration.

getZkServers

@Deprecated
String getZkServers(String configName)

Deprecated. since 10.2 NXP-24634: we don't want to depend anymore on Zookeeper

Returns the Zookeeper servers for a configuration.

getProducerProperties

Properties getProducerProperties(String configName)

Returns the Kafka producer properties for a configuration.

getConsumerProperties

Properties getConsumerProperties(String configName)

Returns the kafka consumer properties for a configuration.

getTopicPrefix

String getTopicPrefix(String configName)

Returns the topic prefix to use for a configuration.