[
https://issues.apache.org/jira/browse/BAHIR-295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17462431#comment-17462431
]
Md Mehrab Alam commented on BAHIR-295:
--------------------------------------
PR: https://github.com/apache/bahir/pull/101
> Backpressure & Rate limiting support in streaming pubsub connector
> ------------------------------------------------------------------
>
> Key: BAHIR-295
> URL: https://issues.apache.org/jira/browse/BAHIR-295
> Project: Bahir
> Issue Type: Improvement
> Components: Spark Streaming Connectors
> Reporter: Md Mehrab Alam
> Priority: Minor
> Labels: GCP, pubsub, spark
>
> In spark streaming pubsub connector, receiver is using reliable store (i.e
> store(iterator)) which does not support rate limit and backpressure.
>
> This Jira is for adding rate limit and backpressure in streaming pubsub
> connector.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
