ConsumeGCPubSub 2.3.0

Bundle
org.apache.nifi | nifi-gcp-nar
Description
Consumes messages from the configured Google Cloud PubSub subscription. The 'Batch Size' property specified the maximum number of messages that will be pulled from the subscription in a single request. The 'Processing Strategy' property specifies if each message should be its own FlowFile or if messages should be grouped into a single FlowFile. Using the Demarcator strategy will provide best throughput when the format allows it. Using Record allows to convert data format as well as doing schema enforcement. Using the FlowFile strategy will generate one FlowFile per message and will have the message's attributes as FlowFile attributes.
Tags
consume, gcp, google, google-cloud, message, pubsub
Input Requirement
FORBIDDEN
Supports Sensitive Dynamic Properties
false
Properties
Relationships
Name Description
success FlowFiles are routed to this relationship after a successful Google Cloud Pub/Sub operation.
Writes Attributes
Name Description
gcp.pubsub.ackId Acknowledgement Id of the consumed Google Cloud PubSub message
gcp.pubsub.messageSize Serialized size of the consumed Google Cloud PubSub message
gcp.pubsub.attributesCount Number of attributes the consumed PubSub message has, if any
gcp.pubsub.publishTime Timestamp value when the message was published
gcp.pubsub.subscription Name of the PubSub subscription
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
See Also