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!

Reply via email to