Carles created BEAM-13754:
-----------------------------
Summary: Add support for CloudEvent 1.0 specification
Key: BEAM-13754
URL: https://issues.apache.org/jira/browse/BEAM-13754
Project: Beam
Issue Type: New Feature
Components: beam-model, extensions-ideas
Reporter: Carles
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.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
