Nitin Chauhan created BAHIR-300: ----------------------------------- Summary: Source topic info in received message attribute for multi topic stream Key: BAHIR-300 URL: https://issues.apache.org/jira/browse/BAHIR-300 Project: Bahir Issue Type: Improvement Components: Spark Streaming Connectors Reporter: Nitin Chauhan
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)