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 Any comments are welcomed, especially if there are better ways of doing things. Cheers!