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.

Field Summary

Fields

Modifier and Type	Field and Description
static String	ALLOWED_PATHS_CONFIG
static String	ALLOWED_PATHS_DOC

Constructor Summary

Constructors

Constructor and Description
FileConfigProvider()

Method Summary

Modifier and Type	Method and 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(Path 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

Field Detail

ALLOWED_PATHS_CONFIG

public static final String ALLOWED_PATHS_CONFIG

See Also:

Constant Field Values

ALLOWED_PATHS_DOC

public static final String ALLOWED_PATHS_DOC

See Also:

Constant Field Values

Constructor Detail

FileConfigProvider

public FileConfigProvider()

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 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(Path path)
                 throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable