Need a more obvious way to set event time in a message #856
Description
EventTime is useful in deciding when to advance high watermarks for streaming engines (Beam/Spark/Flink). Right now to set event time in a message published to Pub/Sub Lite, one needs to use a custom attribute of key "x-goog-pubsublite-event-time-timestamp-proto" and pass in a string using MessageTransforms.encodeAttributeEventTime():
import com.google.cloud.pubsublite.cloudpubsub.MessageTransforms;
// ..
String eventTime = MessageTransforms
.encodeAttributeEventTime(Timestamp.newBuilder().setSeconds(100).build());
ByteString data = ByteString.copyFromUtf8(message);
PubsubMessage pubsubMessage =
PubsubMessage.newBuilder()
.setData(data)
.putAttributes("x-goog-pubsublite-event-time-timestamp-proto", eventTime)
.build();
ApiFuture<String> future = publisher.publish(pubsubMessage);Is there a better way to surface EventTime from the protos?