Hi,

is it possible the get somehow the messageId field of a Pub/Sub message in
a DoFn after using the PubSubIO Beam source to read the messages?

I need the default id which was assigned by the Pub/Sub service. I want to
log it for debugging purposes.

Using a custom attribute for the unique id and the withIdAttribute() method
is not possible for me, because I have no influence on the publisher in
this case.

I use the 2.2.0 version of the Dataflow Java SDK.

Thanks,

Csabi

Reply via email to