Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-1058

Allow to emit alternative event representations through EmbeddedEngine

    XMLWordPrintable

Details

    • Task
    • Resolution: Obsolete
    • Major
    • None
    • None
    • None
    • None

    Description

      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

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              gunnar.morling Gunnar Morling
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: