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

[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 6b1c68a8d fix5
6b1c68a8d is described below

commit 6b1c68a8d3d7fcaf82e16e3bc28597212b2c69c1
Author: Martin Zink <martinz...@apache.org>
AuthorDate: Thu Jun 18 15:44:18 2026 +0200

    fix5
---
 extensions/kafka/ConsumeKafka.cpp | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/extensions/kafka/ConsumeKafka.cpp 
b/extensions/kafka/ConsumeKafka.cpp
index facc83cae..f44d9c174 100644
--- a/extensions/kafka/ConsumeKafka.cpp
+++ b/extensions/kafka/ConsumeKafka.cpp
@@ -66,7 +66,10 @@ minifi_status 
ConsumeKafka::onScheduleImpl(api::core::ProcessContext& context) {
 
   configureNewConnection(context);
   if (commit_policy_ == 
consume_kafka::CommitPolicyEnum::CommitFromIncomingFlowFiles) {
-    context.setTriggerWhenEmpty(true);
+    context.setTriggerWhenEmpty(true).transform_error([&](const 
std::error_code err) {
+      logger_->log_error("Couldnt set trigger when empty due to: {}", 
err.message());
+      return err;
+    });
   }
   return MINIFI_STATUS_SUCCESS;
 }