public abstract class AbstractPolicyConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier | Constructor and Description |
---|---|
protected |
AbstractPolicyConfig(org.apache.kafka.common.config.ConfigDef configDef,
Map<String,?> clientConfigs) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkPolicyMax(Map<String,String> configs,
String maxPolicyConfigProperty,
String configProperty) |
protected void |
checkPolicyMin(Map<String,String> configs,
String minPolicyConfigProperty,
String configProperty) |
protected List<String> |
parseList(Map<String,String> configs,
String configName) |
protected long |
parseLong(String policyConfigProperty) |
documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
protected final void checkPolicyMax(Map<String,String> configs, String maxPolicyConfigProperty, String configProperty)
protected final void checkPolicyMin(Map<String,String> configs, String minPolicyConfigProperty, String configProperty)
protected final long parseLong(String policyConfigProperty)