Module io.aiven.commons.kafka.config

Package io.aiven.commons.kafka.config.validator

Class PredicateGatedValidator

java.lang.Object

io.aiven.commons.kafka.config.validator.PredicateGatedValidator

All Implemented Interfaces:

org.apache.kafka.common.config.ConfigDef.Validator

public class PredicateGatedValidator
extends Object
implements org.apache.kafka.common.config.ConfigDef.Validator

A validator that is gated by a predicate. The predicate tests the value object. If the predicate returns true then the associated validator is executed. Othewise the validation passes.

Constructor Summary

Constructors

Constructor	Description
PredicateGatedValidator(Predicate<Object> predicate, org.apache.kafka.common.config.ConfigDef.Validator validator)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	ensureValid(String name, Object value)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

PredicateGatedValidator

public PredicateGatedValidator(Predicate<Object> predicate,
 org.apache.kafka.common.config.ConfigDef.Validator validator)

Constructor.

Parameters:

predicate - the predicate to gate access to the validator

validator - the validator to execute if the predicate is true.

Method Details

ensureValid

public void ensureValid(String name,
 Object value)

Specified by:

ensureValid in interface org.apache.kafka.common.config.ConfigDef.Validator

toString

public String toString()

Overrides:

toString in class Object