Package org.nuxeo.runtime.kafka

Interface KafkaConfigService

All Known Implementing Classes:
KafkaConfigServiceImpl
public interface KafkaConfigService
Service to collect kafka configurations.
Since:
9.3

  • Method Details

    • listConfigNames

      Set<String> listConfigNames()
      List the name of the registered Kafka 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.

    • getAdminProperties

      Properties getAdminProperties(String kafkaConfig)
      Returns the Kafka admin properties for a configuration.
      Since:
      11.1