in app/pubsub-integration/avro/avro.go [50:63]
func DecodeFromJSON(codec *goavro.Codec, json []byte) (map[string]interface{}, error) {
native, _, err := codec.NativeFromTextual(json)
if err != nil {
log.Println("fail to decode json=", json, "err=", err)
return nil, err
}
data, ok := native.(map[string]interface{})
if !ok {
log.Println("fail to decode json=", json, "err=", err)
return nil, err
}
return data, err
}