如何在PubSubTemplate中指定流控参数?

发布于 2025-01-17 11:05:10 字数 1296 浏览 1 评论 0 原文

我正在使用 pull 方法将消息从指定的 pubsub 订阅中拉出 https://docs.spring.io/spring-cloud-gcp/docs/current/reference/html/#pull-methods,我看到设置最大消息数的选项,但是没有看到指定的方法流量控制参数,如 https://docs.spring.io/spring-cloud-gcp/docs/current/reference/html/#publishersubscriber-configuration

通过调试,我看到 20MB 设置为 max-outstanding -request-bytes (屏幕截图)虽然它说 DEFAULT_FLOW_CONTROL_SETTING 应该有 100MB https://github.com/googleapis/java-pubsub/blob/main/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java#L456

有没有办法让我指定该值?我需要使用 PubSubTemplate 和 pull 方法!

春季启动:2.3.5.RELEASE spring-cloud-gcp-starter-pubsub:2.0.7

谢谢 输入图片此处描述

I am using pull method to pull the messages out of my pubsub subscription as specified https://docs.spring.io/spring-cloud-gcp/docs/current/reference/html/#pull-methods, I see option to set max number of messages but don't see a way to specify the flow control params like max-outstanding-element-count and max-outstanding-request-bytes as in https://docs.spring.io/spring-cloud-gcp/docs/current/reference/html/#publishersubscriber-configuration

By debugging, i see 20MB is set to max-outstanding-request-bytes (screenshot) though it says DEFAULT_FLOW_CONTROL_SETTING should have 100MB https://github.com/googleapis/java-pubsub/blob/main/google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java#L456

is there a way so that i can specify that value? I need to use PubSubTemplate with pull method!

Spring Boot: 2.3.5.RELEASE
spring-cloud-gcp-starter-pubsub: 2.0.7

Thanks
enter image description here

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文