proto-scalapb-to-avro4s
The idea is to define @AvroName annotations in proto files using ScalaPB field options.
Kafka[Protobuf] -> ScalaPB (Apache Beam/Scala) -> Avro4s -> BigQuery[Avro/TableRow/TableSchema]
The idea is to define @AvroName annotations in proto files using ScalaPB field options.
Kafka[Protobuf] -> ScalaPB (Apache Beam/Scala) -> Avro4s -> BigQuery[Avro/TableRow/TableSchema]