/**
* A condition on ConnectRecords.
* Implementations of this interface can be used for filtering records and conditionally applying Transformations.
* Implementations must be public and have a public constructor with no parameters.
*/
public interface Predicate<R extends ConnectRecord<R>> extends Configurable, AutoCloseable {

    /** 
     * Configuration specification for this predicate. 
     */
    ConfigDef config();

    /**
     * Returns whether the given record satisfies this predicate.
     */
    boolean test(R record);

    @Override
    void close();
}