Skip to content


KStreamFilter is a ProcessorSupplier of KStreamFilterProcessors.

Creating Instance

KStreamFilter takes the following to be created:

  • Predicate
  • filterNot flag

KStreamFilter is created when:


Processor<K, V, K, V> get()

get creates a new KStreamFilterProcessor.

get is part of the ProcessorSupplier abstraction.


KStreamFilterProcessor is a ContextualProcessor

Processing Record

void process(
  Record<K, V> record)

process requests the ProcessorContext to forward the given record when either the filterNot flag or the Predicate is true but not both (XOR).

process is part of the Processor abstraction.

Back to top