Class FileConfigProvider

java.lang.Object
org.apache.kafka.common.config.provider.FileConfigProvider
All Implemented Interfaces:
Closeable, AutoCloseable, ConfigProvider, Configurable

public class FileConfigProvider
extends Object
implements ConfigProvider
An implementation of ConfigProvider that represents a Properties file. All property keys and values are stored as cleartext.
  • Constructor Details

    • FileConfigProvider

      public FileConfigProvider()
  • Method Details

    • configure

      public void configure​(Map<String,​?> configs)
      Description copied from interface: Configurable
      Configure this class with the given key-value pairs
      Specified by:
      configure in interface Configurable
    • get

      public ConfigData get​(String path)
      Retrieves the data at the given Properties file.
      Specified by:
      get in interface ConfigProvider
      Parameters:
      path - the file where the data resides
      Returns:
      the configuration data
    • get

      public ConfigData get​(String path, Set<String> keys)
      Retrieves the data with the given keys at the given Properties file.
      Specified by:
      get in interface ConfigProvider
      Parameters:
      path - the file where the data resides
      keys - the keys whose values will be retrieved
      Returns:
      the configuration data
    • reader

      protected Reader reader​(String path) throws IOException
      Throws:
      IOException
    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable