You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "ASF subversion and git services (Jira)" <ji...@apache.org> on 2023/10/01 23:34:00 UTC

[jira] [Commented] (NIFI-8531) Upgrade Kinesis Client Library to 2.x

    [ https://issues.apache.org/jira/browse/NIFI-8531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17770937#comment-17770937 ] 

ASF subversion and git services commented on NIFI-8531:
-------------------------------------------------------

Commit ff8f1ff686399791b55b9d068cb33fdb906e242b in nifi's branch refs/heads/main from Joe Gresock
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=ff8f1ff686 ]

NIFI-8531: This closes #7529. Upgrading Kinesis processors to AWS SDK 2.x

Signed-off-by: Joseph Witt <jo...@apache.org>


> Upgrade Kinesis Client Library to 2.x
> -------------------------------------
>
>                 Key: NIFI-8531
>                 URL: https://issues.apache.org/jira/browse/NIFI-8531
>             Project: Apache NiFi
>          Issue Type: Improvement
>            Reporter: Chris Sampson
>            Assignee: Joe Gresock
>            Priority: Major
>             Fix For: 2.0.0
>
>          Time Spent: 3h 50m
>  Remaining Estimate: 0h
>
> The Kinesis Client Library [KCL] version 1.x is used by the {{ConsumeKinesisStream}} processor (NIFI-2892).
> It would be better to upgrade to KCL 2.x as it is more up-to-date and provides more advanced features.
> For example, the {{WorkerStateChangeListener}} in 2.x has an {{onAllInitializationAttemptsFailed}} method that could be used to better track {{Worker}} startup issues (instead of relying on checking for unexpected {{WorkerState}} values in our processor's {{onTrigger}} method).
> There are also more configuration options available that would be worth considering as processor properties/noting in the processor documentation.
> N.B. upgrading to KCL 2.x relies upon upgrading to AWS Java SDK 2.x first (NIFI-8287).



--
This message was sent by Atlassian Jira
(v8.20.10#820010)