Class DirectoryConfigProvider
- java.lang.Object
-
- org.apache.kafka.common.config.provider.DirectoryConfigProvider
-
- All Implemented Interfaces:
Closeable
,AutoCloseable
,ConfigProvider
,Configurable
public class DirectoryConfigProvider extends Object implements ConfigProvider
An implementation ofConfigProvider
based on a directory of files. Property keys correspond to the names of the regular (i.e. non-directory) files in a directory given by the path parameter. Property values are taken from the file contents corresponding to each key.
-
-
Constructor Summary
Constructors Constructor Description DirectoryConfigProvider()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
configure(Map<String,?> configs)
Configure this class with the given key-value pairsConfigData
get(String path)
Retrieves the data contained in regular files in the directory given bypath
.ConfigData
get(String path, Set<String> keys)
Retrieves the data contained in the regular files named bykeys
in the directory given bypath
.-
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.kafka.common.config.provider.ConfigProvider
subscribe, unsubscribe, unsubscribeAll
-
-
-
-
Method Detail
-
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 interfaceConfigurable
-
close
public void close() throws IOException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-
get
public ConfigData get(String path)
Retrieves the data contained in regular files in the directory given bypath
. Non-regular files (such as directories) in the given directory are silently ignored.- Specified by:
get
in interfaceConfigProvider
- Parameters:
path
- the directory where data files reside.- Returns:
- the configuration data.
-
get
public ConfigData get(String path, Set<String> keys)
Retrieves the data contained in the regular files named bykeys
in the directory given bypath
. Non-regular files (such as directories) in the given directory are silently ignored.- Specified by:
get
in interfaceConfigProvider
- Parameters:
path
- the directory where data files reside.keys
- the keys whose values will be retrieved.- Returns:
- the configuration data.
-
-