/proto-scalapb-to-avro4s

PoC - ScalaPB to Avro4s field name conversion via annotations

Primary LanguageScala

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]