我正在使用带有流量控制的 Google PubSub (RPC StreamingPullRequest API) 的 Node JS 客户端。我的订阅选项如下所示:
{
streamingOptions: {
// decrease this to reduce re-deliveries
maxStreams: 2, // default: 5
},
flowControl: {
allowExcessMessages: false,
maxMessages: 4000, // No issues at 2000
},
},
我将 maxStreams 从 5(默认)减少到 2,以减少重新交付,如文档中此处所述。当我将 maxMessages 设置为 4000 时,我收到以下调试警告,这会导致消息重新传递:
Pubsub subscription received debug message: Failed to "ack" for 3000 message(s). Reason: 3 INVALID_ARGUMENT: Request payload size exceeds the limit: 524288 bytes.
为什么我会收到警告,如何增加有效负载大小?
Node 库 GitHub 存储库 中提出问题,以便进行调查。