You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@bahir.apache.org by "Md Mehrab Alam (Jira)" <ji...@apache.org> on 2021/12/20 07:45:00 UTC

[jira] [Commented] (BAHIR-295) Backpressure & Rate limiting support in streaming pubsub connector

    [ 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)