Package org.nuxeo.runtime.kafka
Interface KafkaConfigService
-
- All Known Implementing Classes:
KafkaConfigServiceImpl
public interface KafkaConfigService
Service to collect kafka configurations.- Since:
- 9.3
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Properties
getAdminProperties(String kafkaConfig)
Returns the Kafka admin properties for a configuration.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.Set<String>
listConfigNames()
List the name of the registered Kafka configuration.
-
-
-
Method Detail
-
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.
-
getAdminProperties
Properties getAdminProperties(String kafkaConfig)
Returns the Kafka admin properties for a configuration.- Since:
- 11.1
-
-