What protobuf version did you use for generating the Message object? It looks like ProtoCoder supports both 2 and 3.
https://github.com/apache/beam/blob/master/sdks/java/extensions/protobuf/src/main/java/org/apache/beam/sdk/extensions/protobuf/ProtoCoder.java#L70 On Wed, May 13, 2020 at 6:43 AM Thinh Ha <[email protected]> wrote: > 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 <+44%2020%203820%208009> > >
