Skip to content

Commit

Permalink
Rebase
Browse files Browse the repository at this point in the history
  • Loading branch information
adamdebreceni committed Dec 2, 2024
1 parent 3a3585e commit 53c2983
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion extensions/kafka/ConsumeKafka.h
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@
#include "core/PropertyDefinitionBuilder.h"
#include "core/PropertyType.h"
#include "core/RelationshipDefinition.h"
#include "core/logging/LoggerConfiguration.h"
#include "core/logging/LoggerFactory.h"
#include "io/StreamPipe.h"
#include "rdkafka.h"
#include "rdkafka_utils.h"
Expand Down
4 changes: 2 additions & 2 deletions extensions/kafka/KafkaProcessorBase.h
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ enum class SecurityProtocolOption { plaintext, ssl, sasl_plaintext, sasl_ssl };
enum class SASLMechanismOption { GSSAPI, PLAIN };
} // namespace kafka

class KafkaProcessorBase : public core::Processor {
class KafkaProcessorBase : public core::ProcessorImpl {
public:
EXTENSIONAPI static constexpr auto SSLContextService =
core::PropertyDefinitionBuilder<>::createProperty("SSL Context Service")
Expand Down Expand Up @@ -90,7 +90,7 @@ class KafkaProcessorBase : public core::Processor {

KafkaProcessorBase(
const std::string_view name, const utils::Identifier& uuid, std::shared_ptr<core::logging::Logger> logger)
: core::Processor(name, uuid),
: core::ProcessorImpl(name, uuid),
logger_(std::move(logger)) {}

KafkaProcessorBase(const KafkaProcessorBase&) = delete;
Expand Down
2 changes: 1 addition & 1 deletion extensions/kafka/PublishKafka.h
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@
#include "core/PropertyType.h"
#include "core/RelationshipDefinition.h"
#include "core/logging/Logger.h"
#include "core/logging/LoggerConfiguration.h"
#include "core/logging/LoggerFactory.h"
#include "rdkafka.h"
#include "utils/ArrayUtils.h"
#include "utils/RegexUtils.h"
Expand Down
2 changes: 1 addition & 1 deletion utils/include/utils/SmallString.h
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ struct fmt::formatter<org::apache::nifi::minifi::utils::SmallString<N>> {
}

template <typename FormatContext>
auto format(const org::apache::nifi::minifi::utils::SmallString<N>& small_string, FormatContext& ctx) {
auto format(const org::apache::nifi::minifi::utils::SmallString<N>& small_string, FormatContext& ctx) const {
return string_view_formatter.format(small_string.view(), ctx);
}
};

0 comments on commit 53c2983

Please sign in to comment.