从Google Cloud Pub/Sub而不是base64获取未编码的数据

dao*_*udc 12 python java google-cloud-pubsub

我正在尝试将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));
Run Code Online (Sandbox Code Playgroud)

但是,尝试通过控制台发送消息时也会发生同样的事情.

最近有什么变化意味着数据不再是base64编码的吗?