Package org.apache.kafka.common.config
Class ConfigDef.LambdaValidator
java.lang.Object
org.apache.kafka.common.config.ConfigDef.LambdaValidator
- All Implemented Interfaces:
ConfigDef.Validator
- Enclosing class:
- ConfigDef
public static class ConfigDef.LambdaValidator extends Object implements ConfigDef.Validator
-
Method Summary
Modifier and Type Method Description voidensureValid(String name, Object value)Perform single configuration validation.StringtoString()static ConfigDef.LambdaValidatorwith(BiConsumer<String,Object> ensureValid, Supplier<String> toStringFunction)
-
Method Details
-
with
public static ConfigDef.LambdaValidator with(BiConsumer<String,Object> ensureValid, Supplier<String> toStringFunction) -
ensureValid
Description copied from interface:ConfigDef.ValidatorPerform single configuration validation.- Specified by:
ensureValidin interfaceConfigDef.Validator- Parameters:
name- The name of the configurationvalue- The value of the configuration
-
toString
-