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

Add option to export change events in "CloudEvents" format

    Details

    • Type: Task
    • Status: Pull Request Sent (View Workflow)
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: core-library
    • Labels:
      None

      Description

      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.

        Gliffy Diagrams

          Attachments

            Activity

              People

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

                Dates

                • Created:
                  Updated: