Interface Predicate<R extends ConnectRecord<R>>
- Type Parameters:
R
- The type of record.
- All Superinterfaces:
AutoCloseable
,Configurable
A predicate on records.
Predicates can be used to conditionally apply a Transformation
by configuring the transformation's predicate
(and negate
) configuration parameters.
In particular, the Filter
transformation can be conditionally applied in order to filter
certain records from further processing.
Implementations of this interface must be public and have a public constructor with no parameters.
-
Method Summary
Methods inherited from interface org.apache.kafka.common.Configurable
configure
-
Method Details
-
config
ConfigDef config()Configuration specification for this predicate.- Returns:
- the configuration definition for this predicate; never null
-
test
Returns whether the given record satisfies this predicate.- Parameters:
record
- the record to evaluate; may not be null- Returns:
- true if the predicate matches, or false otherwise
-
close
void close()- Specified by:
close
in interfaceAutoCloseable
-