Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-13754

Add support for CloudEvent 1.0 specification

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Open
    • P3
    • Resolution: Unresolved
    • None
    • None
    • beam-model, extensions-ideas

    Description

      Add support for CloudEvent 1.0 specification.

      Since the CloudEvent spec is gaining popularity and the 1.0 version is stable, it would be nice to have apache beam support for this specification when processing inbound and outbound messages.

      It currently exists an specification of how CloudEvents must be sent in PubSub and RocketMQ: https://github.com/cloudevents/spec/blob/main/cloudevents/proprietary-specs.md

      The PubSub Message is already a IO class, and it would be great to add a transformation that allow developers to transform a PubsubMessage PCollection to a CloudEvent PCollection and the other way around out of the box.

       

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            CarlesCF Carles
            Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

              Created:
              Updated: