Each Kamelet should be able to consume CloudEvent data format. At least provide some auto conversion to required input format.

Recognize special CoudEvent headers

Read CoudEvent payload data (e.g. from headers, from Json)

Add support for producing CloudEvent output format auto converting the Kamelet output to a CloudEvent setting specific headers and payload according to the CloudEvent specification.