This is an automated email from the ASF dual-hosted git repository.
bbende pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 536dbb7 NIFI-7703 updated all commons codec references to 1.14
new 1df7025 NIFI-7522 : Add Kafka 2.5 Processors set
new 93e5abf NIFI-7522 Updating LICENSE and NOTICE for Kafka 2.5 NAR
The 2 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:
nifi-assembly/LICENSE | 241 ++++---
nifi-assembly/pom.xml | 6 +
.../nifi-kafka-bundle/nifi-kafka-2-5-nar/pom.xml | 41 ++
.../src/main/resources/META-INF/LICENSE | 260 ++++++++
.../src/main/resources/META-INF/NOTICE | 83 +++
.../nifi-kafka-2-5-processors/pom.xml | 137 ++++
.../kafka/pubsub/ConsumeKafkaRecord_2_5.java | 418 ++++++++++++
.../processors/kafka/pubsub/ConsumeKafka_2_5.java | 405 ++++++++++++
.../processors/kafka/pubsub/ConsumerLease.java | 716 +++++++++++++++++++++
.../nifi/processors/kafka/pubsub/ConsumerPool.java | 0
.../kafka/pubsub/InFlightMessageTracker.java | 0
.../kafka/pubsub/KafkaProcessorUtils.java | 0
.../nifi/processors/kafka/pubsub/Partitioners.java | 0
.../kafka/pubsub/PublishKafkaRecord_2_5.java | 560 ++++++++++++++++
.../processors/kafka/pubsub/PublishKafka_2_5.java | 522 +++++++++++++++
.../processors/kafka/pubsub/PublishResult.java | 0
.../processors/kafka/pubsub/PublisherLease.java | 0
.../processors/kafka/pubsub/PublisherPool.java | 0
.../record/sink/kafka/KafkaRecordSink_2_5.java | 397 ++++++++++++
.../org.apache.nifi.controller.ControllerService | 15 +
.../services/org.apache.nifi.processor.Processor | 18 +
.../additionalDetails.html | 205 ++++++
.../additionalDetails.html | 205 ++++++
.../additionalDetails.html | 193 ++++++
.../additionalDetails.html | 205 ++++++
.../processors/kafka/pubsub/ConsumerPoolTest.java | 0
.../kafka/pubsub/ITConsumeKafka_2_5.java | 135 ++++
.../kafka/pubsub/KafkaProcessorUtilsTest.java | 0
.../kafka/pubsub/TestConsumeKafkaRecord_2_5.java | 292 +++++++++
.../kafka/pubsub/TestConsumeKafka_2_5.java | 128 ++++
.../kafka/pubsub/TestInFlightMessageTracker.java | 0
.../kafka/pubsub/TestPublishKafkaRecord_2_5.java | 390 +++++++++++
.../kafka/pubsub/TestPublishKafka_2_5.java | 273 ++++++++
.../kafka/pubsub/TestPublisherLease.java | 0
.../processors/kafka/pubsub/TestPublisherPool.java | 0
.../kafka/pubsub/util/MockRecordParser.java | 0
.../record/sink/kafka/TestKafkaRecordSink_2_5.java | 211 ++++++
.../src/test/resources/log4j.properties | 0
.../src/test/resources/server.properties | 0
.../src/test/resources/zookeeper.properties | 0
nifi-nar-bundles/nifi-kafka-bundle/pom.xml | 10 +-
41 files changed, 5958 insertions(+), 108 deletions(-)
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-nar/pom.xml
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-nar/src/main/resources/META-INF/LICENSE
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-nar/src/main/resources/META-INF/NOTICE
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/pom.xml
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaRecord_2_5.java
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_2_5.java
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerPool.java
(100%)
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/main/java/org/apache/nifi/processors/kafka/pubsub/InFlightMessageTracker.java
(100%)
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/main/java/org/apache/nifi/processors/kafka/pubsub/KafkaProcessorUtils.java
(100%)
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/main/java/org/apache/nifi/processors/kafka/pubsub/Partitioners.java
(100%)
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_2_5.java
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_2_5.java
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishResult.java
(100%)
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherLease.java
(100%)
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherPool.java
(100%)
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/main/java/org/apache/nifi/record/sink/kafka/KafkaRecordSink_2_5.java
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/main/resources/META-INF/services/org.apache.nifi.controller.ControllerService
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/main/resources/META-INF/services/org.apache.nifi.processor.Processor
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_2_5/additionalDetails.html
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_2_5/additionalDetails.html
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_2_5/additionalDetails.html
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.PublishKafka_2_5/additionalDetails.html
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumerPoolTest.java
(100%)
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ITConsumeKafka_2_5.java
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/test/java/org/apache/nifi/processors/kafka/pubsub/KafkaProcessorUtilsTest.java
(100%)
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestConsumeKafkaRecord_2_5.java
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestConsumeKafka_2_5.java
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestInFlightMessageTracker.java
(100%)
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublishKafkaRecord_2_5.java
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublishKafka_2_5.java
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublisherLease.java
(100%)
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublisherPool.java
(100%)
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/test/java/org/apache/nifi/processors/kafka/pubsub/util/MockRecordParser.java
(100%)
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-5-processors/src/test/java/org/apache/nifi/record/sink/kafka/TestKafkaRecordSink_2_5.java
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/test/resources/log4j.properties (100%)
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/test/resources/server.properties (100%)
copy nifi-nar-bundles/nifi-kafka-bundle/{nifi-kafka-2-0-processors =>
nifi-kafka-2-5-processors}/src/test/resources/zookeeper.properties (100%)
