func processPubSubMsgFn(ctx context.Context, in *pubsub.PubsubMessage) v1.someProto {
someProto := &v1.someProto{}
if err := proto.Unmarshal((in.Data), someProto); err != nil {
log.Fatalln("Failed to parse address book:", err)
}
return *someProto
}
Причины: неверный тип возвращаемого значения вызванный: структура кодирования v1.someProto тип имеет неэкспортированное поле: состояние
При попытке запустить конвейер в java я устанавливал кодировщик для типа сообщения, но не знаю, как это сделать в версии Go Apache Beam
Мне пришлось добавить beam.RegisterType(reflect.TypeOf(v1. someProto{})) в функцию init().