KStreamFilter¶

KStreamFilter is a ProcessorSupplier of KStreamFilterProcessors.

Creating Instance¶

KStreamFilter takes the following to be created:

• Predicate
• filterNot flag

KStreamFilter is created when:

• KStreamImpl is requested to filter, filterNot and create a repartitioned source

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.