KSPROCESSOR

The KSPROCESSOR function creates a Kafka Streams Processor node and adds it to a Kafka Streams topology.

The processor node is defined using a map with the following keys:

KeyDescription
nameName of the node. Must be unique within the topology.
initOptional macro which will be called when the init method of the processor is invoked.
processMacro which will be called for each record. The macro will be called with the record key and value as parameters.
closeOptional macro which will be called when the close method of the processor is invoked.
parentsA list of parent node names.

Signature