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:
| Key | Description |
|---|---|
name | Name of the node. Must be unique within the topology. |
init | Optional macro which will be called when the init method of the processor is invoked. |
process | Macro which will be called for each record. The macro will be called with the record key and value as parameters. |
close | Optional macro which will be called when the close method of the processor is invoked. |
parents | A list of parent node names. |