Interface KafkaConfigService

  • All Known Implementing Classes:
    KafkaConfigServiceImpl

    public interface KafkaConfigService
    Service to collect kafka configurations.
    Since:
    9.3
    • Method Detail

      • 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