This is an automated email from the ASF dual-hosted git repository. martinzink pushed a commit to branch minifi-api-property in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
commit 267ac2dce46bc51117efcbd245d69886ac9c61fa Author: Martin Zink <[email protected]> AuthorDate: Thu Mar 13 13:23:20 2025 +0100 linter fix --- extensions/kafka/ConsumeKafka.cpp | 3 ++- extensions/mqtt/processors/PublishMQTT.cpp | 3 ++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/extensions/kafka/ConsumeKafka.cpp b/extensions/kafka/ConsumeKafka.cpp index 1f0f12558..28513e003 100644 --- a/extensions/kafka/ConsumeKafka.cpp +++ b/extensions/kafka/ConsumeKafka.cpp @@ -142,7 +142,8 @@ void ConsumeKafka::extend_config_from_dynamic_properties(const core::ProcessCont } logger_->log_info("Loading {} extra kafka configuration fields from ConsumeKafka dynamic properties:", dynamic_prop_keys.size()); for (const std::string& key : dynamic_prop_keys) { - std::string value = context.getDynamicProperty(key) | utils::orThrow(fmt::format("This shouldn't happen, dynamic property {} is expected because we just queried the list of dynamic properties", key)); + std::string value = context.getDynamicProperty(key) + | utils::orThrow(fmt::format("This shouldn't happen, dynamic property {} is expected because we just queried the list of dynamic properties", key)); logger_->log_info("{}: {}", key.c_str(), value.c_str()); setKafkaConfigurationField(*conf_, key, value); } diff --git a/extensions/mqtt/processors/PublishMQTT.cpp b/extensions/mqtt/processors/PublishMQTT.cpp index d71ce21a2..9a93e38cd 100644 --- a/extensions/mqtt/processors/PublishMQTT.cpp +++ b/extensions/mqtt/processors/PublishMQTT.cpp @@ -49,7 +49,8 @@ void PublishMQTT::readProperties(core::ProcessContext& context) { throw Exception(PROCESS_SCHEDULE_EXCEPTION, "PublishMQTT: Topic is required"); } retain_ = utils::parseBoolProperty(context, Retain); - message_expiry_interval_ = utils::parseOptionalDurationProperty(context, MessageExpiryInterval) | utils::transform([](const auto&& ms) { return std::chrono::duration_cast<std::chrono::seconds>(ms); }); + message_expiry_interval_ = utils::parseOptionalDurationProperty(context, MessageExpiryInterval) + | utils::transform([](const auto&& ms) { return std::chrono::duration_cast<std::chrono::seconds>(ms); }); in_flight_message_counter_.setEnabled(mqtt_version_ == mqtt::MqttVersions::V_5_0 && qos_ != mqtt::MqttQoS::LEVEL_0); }
