Skip to content Skip to sidebar Skip to footer
Home / Apache Beam / Google Cloud Pubsub / Python

How Do You Access The Message Id From Google Pub/Sub Using Apache Beam?

Post a Comment
I have been testing Apache Beam using the 2.13.0 SDK on Python 2.7.16, pulling simple messages from a Google Pub/Sub subscription in streaming mode, and writing to a Google Big Que

Solution 1:

This is a known issue. A bug report has been filed in JIRA for exposing message_id in PubsubMessage. Please vote up this bug report.


Solution 2:

Looks like this may not be working as intended, and a JIRA issue has been logged: https://issues.apache.org/jira/plugins/servlet/mobile#issue/BEAM-7819


You may like these posts

Post a Comment for "How Do You Access The Message Id From Google Pub/Sub Using Apache Beam?"