public class AbstractConfig
extends java.lang.Object
This class holds both the original configuration that was provided as well as the parsed
Constructor and Description |
---|
AbstractConfig(ConfigDef definition,
java.util.Map<?,?> originals) |
AbstractConfig(ConfigDef definition,
java.util.Map<?,?> originals,
boolean doLog) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object o) |
protected java.lang.Object |
get(java.lang.String key) |
java.lang.Boolean |
getBoolean(java.lang.String key) |
java.lang.Class<?> |
getClass(java.lang.String key) |
<T> T |
getConfiguredInstance(java.lang.String key,
java.lang.Class<T> t)
Get a configured instance of the give class specified by the given configuration key.
|
<T> java.util.List<T> |
getConfiguredInstances(java.lang.String key,
java.lang.Class<T> t)
Get a list of configured instances of the given class specified by the given configuration key.
|
<T> java.util.List<T> |
getConfiguredInstances(java.lang.String key,
java.lang.Class<T> t,
java.util.Map<java.lang.String,java.lang.Object> configOverrides)
Get a list of configured instances of the given class specified by the given configuration key.
|
java.lang.Double |
getDouble(java.lang.String key) |
java.lang.Integer |
getInt(java.lang.String key) |
java.util.List<java.lang.String> |
getList(java.lang.String key) |
java.lang.Long |
getLong(java.lang.String key) |
org.apache.kafka.common.config.types.Password |
getPassword(java.lang.String key) |
java.lang.Short |
getShort(java.lang.String key) |
java.lang.String |
getString(java.lang.String key) |
int |
hashCode() |
void |
ignore(java.lang.String key) |
void |
logUnused()
Log warnings for any unused configurations
|
java.util.Map<java.lang.String,java.lang.Object> |
originals() |
java.util.Map<java.lang.String,java.lang.String> |
originalsStrings()
Get all the original settings, ensuring that all values are of type String.
|
java.util.Map<java.lang.String,java.lang.Object> |
originalsWithPrefix(java.lang.String prefix)
Gets all original settings with the given prefix, stripping the prefix before adding it to the output.
|
java.util.Map<java.lang.String,java.lang.Object> |
originalsWithPrefix(java.lang.String prefix,
boolean strip)
Gets all original settings with the given prefix.
|
protected java.util.Map<java.lang.String,java.lang.Object> |
postProcessParsedConfig(java.util.Map<java.lang.String,java.lang.Object> parsedValues)
Called directly after user configs got parsed (and thus default values got set).
|
ConfigDef.Type |
typeOf(java.lang.String key) |
java.util.Set<java.lang.String> |
unused() |
java.util.Map<java.lang.String,?> |
values() |
java.util.Map<java.lang.String,java.lang.Object> |
valuesWithPrefixOverride(java.lang.String prefix)
Put all keys that do not start with
prefix and their parsed values in the result map and then
put all the remaining keys with the prefix stripped and their parsed values in the result map. |
public AbstractConfig(ConfigDef definition, java.util.Map<?,?> originals, boolean doLog)
public AbstractConfig(ConfigDef definition, java.util.Map<?,?> originals)
protected java.util.Map<java.lang.String,java.lang.Object> postProcessParsedConfig(java.util.Map<java.lang.String,java.lang.Object> parsedValues)
parsedValues
- unmodifiable map of current configurationprotected java.lang.Object get(java.lang.String key)
public void ignore(java.lang.String key)
public java.lang.Short getShort(java.lang.String key)
public java.lang.Integer getInt(java.lang.String key)
public java.lang.Long getLong(java.lang.String key)
public java.lang.Double getDouble(java.lang.String key)
public java.util.List<java.lang.String> getList(java.lang.String key)
public java.lang.Boolean getBoolean(java.lang.String key)
public java.lang.String getString(java.lang.String key)
public ConfigDef.Type typeOf(java.lang.String key)
public org.apache.kafka.common.config.types.Password getPassword(java.lang.String key)
public java.lang.Class<?> getClass(java.lang.String key)
public java.util.Set<java.lang.String> unused()
public java.util.Map<java.lang.String,java.lang.Object> originals()
public java.util.Map<java.lang.String,java.lang.String> originalsStrings()
java.lang.ClassCastException
- if any of the values are not stringspublic java.util.Map<java.lang.String,java.lang.Object> originalsWithPrefix(java.lang.String prefix)
prefix
- the prefix to use as a filterpublic java.util.Map<java.lang.String,java.lang.Object> originalsWithPrefix(java.lang.String prefix, boolean strip)
prefix
- the prefix to use as a filterstrip
- strip the prefix before adding to the output if set truepublic java.util.Map<java.lang.String,java.lang.Object> valuesWithPrefixOverride(java.lang.String prefix)
prefix
and their parsed values in the result map and then
put all the remaining keys with the prefix stripped and their parsed values in the result map.
This is useful if one wants to allow prefixed configs to override default ones.public java.util.Map<java.lang.String,?> values()
public void logUnused()
public <T> T getConfiguredInstance(java.lang.String key, java.lang.Class<T> t)
key
- The configuration key for the classt
- The interface the class should implementpublic <T> java.util.List<T> getConfiguredInstances(java.lang.String key, java.lang.Class<T> t)
key
- The configuration key for the classt
- The interface the class should implementpublic <T> java.util.List<T> getConfiguredInstances(java.lang.String key, java.lang.Class<T> t, java.util.Map<java.lang.String,java.lang.Object> configOverrides)
key
- The configuration key for the classt
- The interface the class should implementconfigOverrides
- Configuration overrides to use.public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object