NIFI-14467 Gracefully stop ConsumeBoxEnterpriseEvents

[awelless]

Summary

NIFI-14467

Tracking

Please complete the following tracking steps prior to pull request creation.

Issue Tracking

• Apache NiFi Jira issue created

Pull Request Tracking

• Pull Request title starts with Apache NiFi Jira issue number, such as NIFI-00000
• Pull Request commit message starts with Apache NiFi Jira issue number, as such NIFI-00000

Pull Request Formatting

• Pull Request based on current revision of the main branch
• Pull Request refers to a feature branch with one commit containing changes

Verification

Please indicate the verification steps performed prior to pull request creation.

Build

• Build completed using mvn clean install -P contrib-check
  • JDK 21

Licensing

• New dependencies are compatible with the Apache License 2.0 according to the License Policy
• New dependencies are documented in applicable LICENSE and NOTICE files

Documentation

• Documentation formatting appears as expected in rendered files

[exceptionfactory]

Thanks @awelless, can you rebase this pull request? That will resolve unrelated unit test failures.

[exceptionfactory]

Instead of having the nested conditional, can the while condition be changed to while (isScheduled())?

[awelless]

The reason for the condition is to provide a reason why we stopped further processing. Similar to when eventLog.getSize() == 0

[exceptionfactory]

Thanks for the response. Given that these are debug logs, not written in the default configuration, I recommend simplifying the implementation and removing this log. The other debug logs that include the stream position are useful, and should provide sufficient details for debugging.

[exceptionfactory]

Thanks for making the adjustments @awelless, the latest version looks good! +1 merging