Beam GCP Pub/Sub : Subscribe


The Beam GCP Pub/Sub : Subscribe transform gets messages from a Google Cloud Pub/Sub topic using a subscription with the Beam execution engine.


Option Description

Transform name

Name of the transform, this name has to be unique in a single pipeline.

Subscription name

Name of the Google Cloud Pub/Sub subscription.

Topic to subscribe to

The Google Cloud Pub/Sub topic.

The type of message to read

  • String

  • PubsubMessage

The output field name

The field containing the result message.