szaszm commented on a change in pull request #1212:
URL: https://github.com/apache/nifi-minifi-cpp/pull/1212#discussion_r750263013
##
File path: extensions/librdkafka/rdkafka_utils.cpp
##
@@ -29,6 +29,9 @@ namespace minifi {
namespace utils {
void setKafkaConfigurationField
szaszm commented on a change in pull request #1212:
URL: https://github.com/apache/nifi-minifi-cpp/pull/1212#discussion_r751139001
##
File path: extensions/librdkafka/PublishKafka.h
##
@@ -89,8 +84,19 @@ class PublishKafka : public core::Processor {
EXTENSIONAPI static const
szaszm commented on a change in pull request #1212:
URL: https://github.com/apache/nifi-minifi-cpp/pull/1212#discussion_r751193030
##
File path: extensions/librdkafka/KafkaProcessorBase.cpp
##
@@ -0,0 +1,135 @@
+/**
+ * @file KafkaProcessorBase.cpp
+ * KafkaProcessorBase class