kafka-streams-internals-KStreamTransformProcessor.adoc

KStreamTransformProcessor

KStreamTransformProcessor is a processor that is used for KStream.transform stateful operator.

KStreamTransformProcessor is created when KStreamTransform is requested for a processor.

KStreamTransformProcessor takes a single Transformer when created.

Closing Processor — close Method

void close()

Note	close is part of the Processor Contract to close the processor.

close…​FIXME

Initializing Processor — init Method

void init(ProcessorContext context)

Note	init is part of the Processor Contract to initialize the processor.

init…​FIXME

Processing Record — process Method

void process(K1 key, V1 value)

Note	process is part of the Processor Contract to process a single record.

process…​FIXME