Skip to content

KStreamFilter

KStreamFilter is a ProcessorSupplier of KStreamFilterProcessors.

Creating Instance

KStreamFilter takes the following to be created:

  • Predicate
  • filterNot flag

KStreamFilter is created when:

get

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

get creates a new KStreamFilterProcessor.

get is part of the ProcessorSupplier abstraction.

KStreamFilterProcessor

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