damccorm opened a new issue, #21286: URL: https://github.com/apache/beam/issues/21286
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](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. Imported from Jira [BEAM-13754](https://issues.apache.org/jira/browse/BEAM-13754). Original Jira may contain additional context. Reported by: CarlesCF. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
