class KTableFilter implements KTableProcessorSupplier<K, V, V> {

    @Override
    public void enableSendingOldValues() {
        parent.enableSendingOldValues();
        sendOldValues = true;
    }

    public  KTableFilter(KTableImpl<K, ?, V> parent, Predicate<K, V> predicate, boolean filterNot);

}