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 d5994722a2d559ef6462dbd4fb1aaec22ca11e07 Author: Martin Zink <[email protected]> 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; }
