[
https://issues.apache.org/jira/browse/MINIFICPP-1210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Marton Szasz updated MINIFICPP-1210:
------------------------------------
Priority: Minor (was: Major)
> Add proper backpressure handling to SourceInitiatedSubscriptionListener
> -----------------------------------------------------------------------
>
> Key: MINIFICPP-1210
> URL: https://issues.apache.org/jira/browse/MINIFICPP-1210
> Project: Apache NiFi MiNiFi C++
> Issue Type: Improvement
> Reporter: Dániel Bakai
> Priority: Minor
>
> Currently there is no backpressure handling at all - FlowFiles are just
> pumped out of the processor.
> Because of its inherent subscription model, this is not trivial to do. Even
> if we don't create FlowFiles, we would have to hold the incoming data in an
> in-memory queue.
> This can probably be solved by generating faults on backpressure and letting
> the sources resubscribe with the saved bookmark at the point of faulting, but
> this is very much untrivial - further parts of the undocumented protocol have
> to be figured out.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
