Currently, the EmbeddedEngine expects an event handler method that takes a SourceRecord. With growing demand for consumption of Debezium's change events by messaging/eventing layers other than Apache Kafka (CloudEvents, Pulsar), this should be generified, e.g. it should also be possible to emit a CloudEvents-JSON-String, or an Avro message (for propagation through Pulsar). This will require:

• Change to the EmbeddedEngine API
• Change to the internals so no SourceRecord is produced but some alternative representation (see RelationalChangeRecordEmitter and related places)
• Change to the internals so that an alternative schema representation is used TableSchema