Hi All, Quick question please, when using PubsubIO.writeProtos, the ProtoCoder is used: https://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java#L571
Does this assume proto2 or proto3? I'm trying to debug a serialization issue with enums which might be due to us using proto3 not proto2. Thank you, -- Thinh Ha [email protected] Strategic Cloud Engineer +44 (0)20 3820 8009
