This is an automated email from the ASF dual-hosted git repository.
szaszm pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git.
from 112e95d MINIFICPP-1676 Check build identifier in extensions
new 767435d MINIFICPP-1677 Add SASL options to Kafka processors
new 6074634 MINIFICPP-1629 Add DeleteAzureDataLakeStorage processor
new 0553df4 MINIFICPP-1692 TLSSocket: Break infinite loop when no more
data can be read
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
PROCESSORS.md | 44 +++-
README.md | 2 +-
cmake/BuildTests.cmake | 13 ++
docker/test/integration/features/kafka.feature | 123 +++++++++++
.../minifi/core/KafkaBrokerContainer.py | 8 +-
.../integration/resources/kafka_broker/Dockerfile | 2 +-
.../kafka_broker/conf/server-ssl.properties | 155 --------------
.../resources/kafka_broker/conf/server.properties | 50 ++++-
.../AzureDataLakeStorageProcessorBase.cpp | 81 +++++++
.../processors/AzureDataLakeStorageProcessorBase.h | 64 ++++++
.../azure/processors/AzureStorageProcessorBase.cpp | 6 +-
.../azure/processors/AzureStorageProcessorBase.h | 2 +-
.../processors/DeleteAzureDataLakeStorage.cpp | 85 ++++++++
.../azure/processors/DeleteAzureDataLakeStorage.h | 67 ++++++
.../azure/processors/PutAzureBlobStorage.cpp | 2 +-
.../azure/processors/PutAzureDataLakeStorage.cpp | 55 +----
.../azure/processors/PutAzureDataLakeStorage.h | 28 +--
extensions/azure/storage/AzureDataLakeStorage.cpp | 9 +
extensions/azure/storage/AzureDataLakeStorage.h | 1 +
.../azure/storage/AzureDataLakeStorageClient.cpp | 8 +-
.../azure/storage/AzureDataLakeStorageClient.h | 9 +-
extensions/azure/storage/DataLakeStorageClient.h | 8 +-
extensions/librdkafka/ConsumeKafka.cpp | 76 ++-----
extensions/librdkafka/ConsumeKafka.h | 15 +-
extensions/librdkafka/KafkaProcessorBase.cpp | 135 ++++++++++++
extensions/librdkafka/KafkaProcessorBase.h | 69 ++++++
extensions/librdkafka/PublishKafka.cpp | 237 +++++----------------
extensions/librdkafka/PublishKafka.h | 25 ++-
.../TLSClientSocketSupportedProtocolsTest.cpp | 118 ++--------
.../tests/unit/GenerateFlowFileTests.cpp | 9 +-
libminifi/include/utils/ProcessorConfigUtils.h | 18 +-
libminifi/src/io/tls/TLSSocket.cpp | 4 +-
libminifi/src/utils/ProcessorConfigUtils.cpp | 18 +-
libminifi/test/SimpleSSLTestServer.h | 130 +++++++++++
.../azure-tests/AzureDataLakeStorageTestsFixture.h | 122 +++++++++++
.../DeleteAzureDataLakeStorageTests.cpp | 128 +++++++++++
.../test/azure-tests/MockDataLakeStorageClient.h | 96 +++++++++
.../test/azure-tests/PutAzureBlobStorageTests.cpp | 3 +-
.../azure-tests/PutAzureDataLakeStorageTests.cpp | 168 ++-------------
libminifi/test/unit/tls/TLSStreamTests.cpp | 82 +++++++
40 files changed, 1495 insertions(+), 780 deletions(-)
delete mode 100644
docker/test/integration/resources/kafka_broker/conf/server-ssl.properties
create mode 100644
extensions/azure/processors/AzureDataLakeStorageProcessorBase.cpp
create mode 100644
extensions/azure/processors/AzureDataLakeStorageProcessorBase.h
create mode 100644 extensions/azure/processors/DeleteAzureDataLakeStorage.cpp
create mode 100644 extensions/azure/processors/DeleteAzureDataLakeStorage.h
create mode 100644 extensions/librdkafka/KafkaProcessorBase.cpp
create mode 100644 extensions/librdkafka/KafkaProcessorBase.h
create mode 100644 libminifi/test/SimpleSSLTestServer.h
create mode 100644
libminifi/test/azure-tests/AzureDataLakeStorageTestsFixture.h
create mode 100644
libminifi/test/azure-tests/DeleteAzureDataLakeStorageTests.cpp
create mode 100644 libminifi/test/azure-tests/MockDataLakeStorageClient.h
create mode 100644 libminifi/test/unit/tls/TLSStreamTests.cpp
