Получение некодированных данных из облака Google Паб /Sub вместо base64

Я пытаюсь использовать библиотеку Python для Pub/Sub, но я продолжаю получать эту ошибку: TypeError: Incorrect padding. Некоторые быстрые поисковые запросы выявили эту проблему: https://github.com/GoogleCloudPlatform/google-cloud-python/pull/2527

Однако это не решает проблему - на самом деле, распечатывая данные, выяснилось, что данные даже не закодированы base64 вообще, а установка data = raw_data в библиотеке разрешила проблему.

Мы отправляем сообщение с Java, вот код, который мы используем:

PCollection<String> userActionsJson = userActionsRaw.apply(ParDo.of(new BigQueryRowToJson()));
       String topicNameFull = "projects/" + options.getProject() + "/topics/" +
               options.getUsersActionsTopicName() + "-" + options.getProduct();
       userActionsJson.apply(PubsubIO.Write.named("PublishToPubSub")
               .topic(topicNameFull));

однако то же самое происходит при попытке отправить сообщение через консоль.

Что-то недавно изменилось, чтобы означать, что данные больше не закодированы base64?

Ответ 1