Alaksiej Ščarbaty created NIFI-15183:
----------------------------------------

             Summary: Generate unique worker id in ConsumeKinesis
                 Key: NIFI-15183
                 URL: https://issues.apache.org/jira/browse/NIFI-15183
             Project: Apache NiFi
          Issue Type: Bug
          Components: Extensions
    Affects Versions: 2.6.0
            Reporter: Alaksiej Ščarbaty
            Assignee: Alaksiej Ščarbaty


`ConsumeKinesis` uses processor's identifier as KCL worker id.

This approach doesn't work in a clustered environment, as workers on different 
nodes will acquire the same id.

The workerId should comprise a processor identifier, as well as an random salt, 
to guarantee uniqueness of a the id across different nodes. 



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

Reply via email to