I have to update a service written in go to consume messages from a new avro kafka topic, before it was just JSON. I originally wrote the code pretty much following the documentation of hamba/avro defining the schema like: