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

Support exporting change events in "CloudEvents" format

XMLWordPrintable

    • Icon: Feature Request Feature Request
    • Resolution: Done
    • Icon: Major Major
    • 1.1.0.Alpha1
    • None
    • core-library
    • None

      CloudEvents is a "specification for describing event data in a common way". It helps with exchanging events in an interoperable way, defining "transport bindings" for protocols like HTTP, AMQP and more (Kafka is currently being worked on).

      We should explore how Debezium could support CloudEvents; on first thought, one way could be to optionally wrap the existing Debezium messages into a CloudEvents envelope (with the Debezium message going into the "data" field of that envelope). There are some open questions, though:

      • How is the interaction with the schema?
      • Would Avro be supported?
      • Should the message key go into a custom field of the envelope (see also related discussion in the Kafka transport binding discussion)

      I think in the first step this wouldn't change the way how Debezium is run, i.e. it'll send messages to Apache Kafka, from where other CloudEvents-aware consumers can pick up the events.

        1. CloudEvents.pdf
          8 kB
          Yuchao Wang
        2. CloudEvents - JSON.png
          35 kB
          Yuchao Wang

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

                Created:
                Updated:
                Resolved: