exceptionfactory commented on code in PR #10526:
URL: https://github.com/apache/nifi/pull/10526#discussion_r2544612487
##########
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-kinesis/src/main/java/org/apache/nifi/processors/aws/kinesis/ConsumeKinesis.java:
##########
@@ -684,6 +728,49 @@ public void shutdownRequested(final ShutdownRequestedInput
shutdownRequestedInpu
}
}
+ private static final class InitializationStateChangeListener implements
WorkerStateChangeListener {
+
+ private final ComponentLog logger;
+
+ private final CompletableFuture<InitializationResult> resultFuture =
new CompletableFuture<>();
+
+ private volatile @Nullable Throwable initializationFailure;
+
+ InitializationStateChangeListener(final ComponentLog logger) {
+ this.logger = logger;
+ }
+
+ @Override
+ public void onWorkerStateChange(final WorkerState newState) {
+ logger.info("Processor state changed to: {}", newState);
Review Comment:
Thanks for clarifying. Since this level is more detailed, keeping it as an
info message looks good.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
