Задание потока данных + большой запрос

У меня следующая проблема: У меня есть большой запрос со следующей схемой:

cpf: string
name: string
greaterOfAge: boolean
foreigner: boolean

И у меня есть pub/sub для отправки сообщений, выровненных с заданием DataFlow, которое использует очень простую функцию UDF. Который вычисляет значение взрослого только в том случае, если пользователь является иностранцем:

function transform(inJson) {
  var obj = JSON.parse(inJson);

  var output = {
    "cpf": obj.cpf,
    "nome": obj.nome,
    "greaterOfAge": true,
    "foreigner": true
  }
return output;
}

Когда я публикую это сообщение через PubSub:

"cpf": "123456–789",
"nome": "Alan Turing",
"age": 20,
"origem": "Inglaterra"

Но я получаю эту ошибку:

{"errors":[{"debugInfo":"","location":"origem","message":"no such field: origem.","reason":"invalid"}],"index":0}

Я использую эту статью как ссылку: https://inside.contabilizei.com.br/streaming-de-dados-com-google-cloud-dataflow-1cd6aa69bae8