This is an automated email from the ASF dual-hosted git repository. martinzink pushed a commit to branch beke_2 in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
commit 27c140d391962fe249ad27f6e7dfea5f49a0bfcd Author: Martin Zink <[email protected]> AuthorDate: Thu Jun 18 17:29:07 2026 +0200 fix6 --- .../cpp-extension-lib/mocklib/include/MockProcessContext.h | 4 +++- extensions/kafka/ConsumeKafka.cpp | 5 +---- 2 files changed, 4 insertions(+), 5 deletions(-) diff --git a/extension-framework/cpp-extension-lib/mocklib/include/MockProcessContext.h b/extension-framework/cpp-extension-lib/mocklib/include/MockProcessContext.h index 1b97a7ed8..a239eed67 100644 --- a/extension-framework/cpp-extension-lib/mocklib/include/MockProcessContext.h +++ b/extension-framework/cpp-extension-lib/mocklib/include/MockProcessContext.h @@ -40,7 +40,9 @@ class MockProcessContext : public api::core::ProcessContext { return {}; } - [[nodiscard]] std::expected<void, std::error_code> setTriggerWhenEmpty(bool) override {} + [[nodiscard]] std::expected<void, std::error_code> setTriggerWhenEmpty(bool) override { + return {}; + } std::map<std::string, std::string, std::less<>> properties_; std::unique_ptr<api::core::PublishedMetrics> last_published_metrics_ = std::make_unique<api::core::PublishedMetrics>(); diff --git a/extensions/kafka/ConsumeKafka.cpp b/extensions/kafka/ConsumeKafka.cpp index f44d9c174..25f63568f 100644 --- a/extensions/kafka/ConsumeKafka.cpp +++ b/extensions/kafka/ConsumeKafka.cpp @@ -66,10 +66,7 @@ minifi_status ConsumeKafka::onScheduleImpl(api::core::ProcessContext& context) { configureNewConnection(context); if (commit_policy_ == consume_kafka::CommitPolicyEnum::CommitFromIncomingFlowFiles) { - context.setTriggerWhenEmpty(true).transform_error([&](const std::error_code err) { - logger_->log_error("Couldnt set trigger when empty due to: {}", err.message()); - return err; - }); + std::ignore = context.setTriggerWhenEmpty(true); } return MINIFI_STATUS_SUCCESS; }
