Hi Cristian, Great!
Would you be interested to add this functionality into original ConfluentSchemaRegistryDeserializerProvider (along with Json support maybe) [1] ? Though, it seems that it will require an update of Confluent deps to at least version 5.5 [2] and it can be blocked by Beam Avro deps update. [1] https://issues.apache.org/jira/browse/BEAM-9330 [2] https://www.confluent.io/blog/introducing-confluent-platform-5-5/ > On 9 Jan 2021, at 05:16, Cristian Constantinescu <zei...@gmail.com> wrote: > > Hi everyone, > > Beam currently has a dependency on older versions of the Confluent libs. It > makes it difficult to use Protobufs with the Confluent Schema Registry as > ConfluentSchemaRegistryDeserializerProvider only supports Avro. > > I put up together a very simple project to demo how it can be done without > touching any files inside of Beam. You can find it here: > https://github.com/zeidoo/beam-confluent-schema-registry-protobuf > <https://github.com/zeidoo/beam-confluent-schema-registry-protobuf> > > Any comments are welcomed, especially if there are better ways of doing > things. > > Cheers!
