Alaksiej Ščarbaty created NIFI-15180:
----------------------------------------
Summary: Log initialization errors in ConsumeKinesis
Key: NIFI-15180
URL: https://issues.apache.org/jira/browse/NIFI-15180
Project: Apache NiFi
Issue Type: Improvement
Components: Extensions
Affects Versions: 2.6.0
Reporter: Alaksiej Ščarbaty
`ConsumeKinesis` processor launches KCL scheduler under the hood. If scheduler
initialization fails for any reason, it's visible in the application logs only.
The processor continues running tasks, without any flow files produced.
Instead, the error should be propagated to the processor's code and then logged
by a `ConsumeKinesis` processor's logger.
It seems that `WorkerStateChangeListener` in the KCL's `coordinatorConfig` is
the right candidate.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
