in app/pubsub-integration/avro/avro.go [41:47]
func EncodeToJSON(codec *goavro.Codec, data map[string]interface{}) ([]byte, error) {
json, err := codec.TextualFromNative(nil, data)
if err != nil {
log.Println("fail to encode data=", data, "err=", err)
}
return json, err
}