[
https://issues.apache.org/jira/browse/NIFI-14629?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17983731#comment-17983731
]
ASF subversion and git services commented on NIFI-14629:
--------------------------------------------------------
Commit acabbad4ad4e0690ecdbe212e86bf5828171beeb in nifi's branch
refs/heads/main from Dariusz Seweryn
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=acabbad4ad ]
NIFI-14629 Added timeout blocking to ConsumeKinesisStream
This closes #9995
Signed-off-by: David Handermann <[email protected]>
> ConsumeKinesisStream backpressure handling may not work
> -------------------------------------------------------
>
> Key: NIFI-14629
> URL: https://issues.apache.org/jira/browse/NIFI-14629
> Project: Apache NiFi
> Issue Type: Bug
> Components: Extensions
> Affects Versions: 2.4.0
> Reporter: Dariusz Seweryn
> Assignee: Dariusz Seweryn
> Priority: Major
> Time Spent: 50m
> Remaining Estimate: 0h
>
> In NIFI-14358 I added backpressure handling in ConsumeKinesisStream. The
> processor gets scheduled even when the output queue is full, in which case it
> stops producing records.
> The processor may not be triggered on overwhelmed nodes in which case it will
> not get backpressured and will continue to overwhelm.
> There should be a stop mechanism added that would trigger when the processor
> is not triggered for X amount of time. 3 seconds?
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
