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)