(nifi-minifi-cpp) branch beke_2 updated: fix6

[martinzink]

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


The following commit(s) were added to refs/heads/beke_2 by this push:
     new 3dffeb4e0 fix6
3dffeb4e0 is described below

commit 3dffeb4e00a30ff716d8150541ad95185792a2de
Author: Martin Zink <martinz...@apache.org>
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;
 }