kafka-streams-internals-KStreamFilter.adoc

KStreamFilter — ProcessorSupplier of KStreamFilterProcessors for filter and filterNot Streaming Operators

KStreamFilter is a ProcessorSupplier of KStreamFilterProcessors.

KStreamFilter is created when KStreamImpl is requested to execute the following streaming operators:

• KStreamImpl.filter

• KStreamImpl.filterNot

• KStreamImpl.createRepartitionedSource

KStreamFilter takes the following when created:

• Predicate (of K keys and V values)

• filterNot flag

KStreamFilter creates a new KStreamFilterProcessor whenever requested to supply one.

KStreamFilterProcessor is an AbstractProcessor that requests the ProcessorContext to forward a record (to downstream processors) only when the Predicate is met.