Consumes message from the configured Google Cloud PubSub Lite subscription.
google, google-cloud, gcp, message, pubsub, consume, lite
In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.
| Display Name | API Name | Default Value | Allowable Values | Description |
|---|---|---|---|---|
| Subscription | gcp-pubsub-subscription | Name of the Google Cloud Pub/Sub Subscription. Example: projects/8476107443/locations/europe-west1-d/subscriptions/my-lite-subscription Supports Expression Language: true (will be evaluated using variable registry only) | ||
| GCP Credentials Provider Service | GCP Credentials Provider Service | Controller Service API: GCPCredentialsService Implementation: GCPCredentialsControllerService | The Controller Service used to obtain Google Cloud Platform credentials. | |
| Bytes Outstanding | gcp-bytes-outstanding | 10 MB | The number of quota bytes that may be outstanding to the client. Supports Expression Language: true (will be evaluated using variable registry only) | |
| Messages Outstanding | gcp-messages-outstanding | 1000 | The number of messages that may be outstanding to the client. Supports Expression Language: true (will be evaluated using variable registry only) |
| Name | Description |
|---|---|
| success | FlowFiles are routed to this relationship after a successful Google Cloud Pub/Sub operation. |
| Name | Description |
|---|---|
| gcp.pubsub.messageId | ID of the pubsub message published to the configured Google Cloud PubSub topic |
| gcp.pubsub.ordering.key | If non-empty, identifies related messages for which publish order should be respected. If a 'Subscription' has 'enable_message_ordering' set to 'true', messages published with the same non-empty 'ordering_key' value will be delivered to subscribers in the order in which they are received by the Pub/Sub system. All 'PubsubMessage's published in a given 'PublishRequest' must specify the same 'ordering_key' value. |
| gcp.pubsub.attributesCount | Number of attributes the consumed PubSub message has, if any |
| gcp.pubsub.publishTime | Timestamp value when the message was published |
| Dynamic Attributes | Other than the listed attributes, this processor may write zero or more attributes, if the original Google Cloud Publisher client added any attributes to the message while sending |