Hi,
from the docs I can see withTimestampAttribute is used to attach a custom
timestamp attribute which can be used by a downstream pipeline while
reading from pubsub.
In my publisher pipeline code I am writing json strings(serialized from
pojos). withTimestampAttribute lets me specify the name of the attribute
which will contain the timestamp but it does not let me set the value of
the timestamp. how to set the timestamp value which will be extracted from
each record being published.
I would like to do something like this -
PubsubIO.writeStrings()
.withTimestampAttribute("attribute_timestamp",
ExtractTimestampEpocFromStringFn())
.to(outputTopicId));
