module documentation
This is the core interface of the function api.
The process method is called for every message of the input topic of the function. The incoming input bytes are deserialized using the serde. The process function can optionally emit an output
| Class | |
Interface for Pulsar Function |