This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
from c25b02711a NIFI-14387 Upgraded Spring to 6.2.5 and Spring Boot to
3.4.4 with others (#9819)
add 9f4b4dc630 NIFI-14358 Added Blocking on Backpressure to
ConsumeKinesisStream (#9812)
No new revisions were added by this update.
Summary of changes:
.../aws/kinesis/stream/ConsumeKinesisStream.java | 14 ++-
.../stream/pause/RecordProcessorBlocker.java | 12 +--
.../pause/StandardRecordProcessorBlocker.java | 29 ++++--
.../record/AbstractKinesisRecordProcessor.java | 11 +-
.../stream/record/KinesisRecordProcessorRaw.java | 5 +-
.../record/KinesisRecordProcessorRecord.java | 5 +-
.../pause/TestStandardRecordProcessorBlocker.java | 114 +++++++++++++++++++++
.../record/TestAbstractKinesisRecordProcessor.java | 3 +-
.../record/TestKinesisRecordProcessorRaw.java | 5 +-
.../record/TestKinesisRecordProcessorRecord.java | 5 +-
10 files changed, 171 insertions(+), 32 deletions(-)
copy
nifi-commons/nifi-hl7-query-language/src/main/java/org/apache/nifi/hl7/model/HL7Segment.java
=>
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/kinesis/stream/pause/RecordProcessorBlocker.java
(84%)
copy
nifi-framework-bundle/nifi-framework/nifi-framework-core-api/src/main/java/org/apache/nifi/registry/flow/StandardFlowRegistryClientUserContext.java
=>
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/kinesis/stream/pause/StandardRecordProcessorBlocker.java
(56%)
create mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/kinesis/stream/pause/TestStandardRecordProcessorBlocker.java
