Package org.apache.kafka.common.config.provider

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 Summary

Constructors

Constructor	Description
FileConfigProvider()

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs)	Configure this class with the given key-value pairs
ConfigData	get(String path)	Retrieves the data at the given Properties file.
ConfigData	get(String path, Set<String> keys)	Retrieves the data with the given keys at the given Properties file.
protected Reader	reader(String path)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.kafka.common.config.provider.ConfigProvider

subscribe, unsubscribe, unsubscribeAll

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