You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ex...@apache.org on 2022/01/19 17:21:08 UTC
[nifi] branch main updated (8edb5fa -> 48c8193)
This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 8edb5fa NIFI-9591 This closes #5674. Removed nifi-kite-bundle
add 48c8193 NIFI-9595 Removed nifi-kafka-0.x modules
No new revisions were added by this update.
Summary of changes:
nifi-assembly/pom.xml | 28 -
.../nifi-kafka-bundle/nifi-kafka-0-10-nar/pom.xml | 41 --
.../src/main/resources/META-INF/LICENSE | 323 ---------
.../src/main/resources/META-INF/NOTICE | 81 ---
.../nifi-kafka-0-10-processors/pom.xml | 128 ----
.../kafka/pubsub/ConsumeKafkaRecord_0_10.java | 348 ----------
.../processors/kafka/pubsub/ConsumeKafka_0_10.java | 337 ----------
.../processors/kafka/pubsub/ConsumerLease.java | 656 -------------------
.../nifi/processors/kafka/pubsub/ConsumerPool.java | 335 ----------
.../kafka/pubsub/InFlightMessageTracker.java | 186 ------
.../kafka/pubsub/KafkaProcessorUtils.java | 393 -----------
.../nifi/processors/kafka/pubsub/Partitioners.java | 62 --
.../kafka/pubsub/PublishKafkaRecord_0_10.java | 382 -----------
.../processors/kafka/pubsub/PublishKafka_0_10.java | 395 ------------
.../processors/kafka/pubsub/PublishResult.java | 56 --
.../processors/kafka/pubsub/PublisherLease.java | 214 ------
.../processors/kafka/pubsub/PublisherPool.java | 98 ---
.../services/org.apache.nifi.processor.Processor | 18 -
.../additionalDetails.html | 142 ----
.../additionalDetails.html | 142 ----
.../additionalDetails.html | 143 ----
.../additionalDetails.html | 155 -----
.../processors/kafka/pubsub/ConsumeKafkaTest.java | 128 ----
.../processors/kafka/pubsub/ConsumerPoolTest.java | 224 -------
.../processors/kafka/pubsub/ITConsumeKafka.java | 135 ----
.../kafka/pubsub/TestConsumeKafkaRecord_0_10.java | 224 -------
.../kafka/pubsub/TestInFlightMessageTracker.java | 87 ---
.../processors/kafka/pubsub/TestPublishKafka.java | 262 --------
.../kafka/pubsub/TestPublishKafkaRecord_0_10.java | 321 ---------
.../kafka/pubsub/TestPublisherLease.java | 293 ---------
.../processors/kafka/pubsub/TestPublisherPool.java | 68 --
.../kafka/pubsub/util/MockRecordParser.java | 105 ---
.../kafka/pubsub/util/MockRecordWriter.java | 128 ----
.../nifi/processors/kafka/test/EmbeddedKafka.java | 226 -------
.../src/test/resources/log4j.properties | 21 -
.../src/test/resources/server.properties | 121 ----
.../src/test/resources/zookeeper.properties | 20 -
.../nifi-kafka-bundle/nifi-kafka-0-11-nar/pom.xml | 41 --
.../src/main/resources/META-INF/LICENSE | 233 -------
.../src/main/resources/META-INF/NOTICE | 83 ---
.../nifi-kafka-0-11-processors/pom.xml | 127 ----
.../kafka/pubsub/ConsumeKafkaRecord_0_11.java | 397 ------------
.../processors/kafka/pubsub/ConsumeKafka_0_11.java | 389 -----------
.../processors/kafka/pubsub/ConsumerLease.java | 718 ---------------------
.../nifi/processors/kafka/pubsub/ConsumerPool.java | 372 -----------
.../kafka/pubsub/InFlightMessageTracker.java | 179 -----
.../kafka/pubsub/KafkaProcessorUtils.java | 405 ------------
.../nifi/processors/kafka/pubsub/Partitioners.java | 62 --
.../kafka/pubsub/PublishKafkaRecord_0_11.java | 461 -------------
.../processors/kafka/pubsub/PublishKafka_0_11.java | 470 --------------
.../processors/kafka/pubsub/PublishResult.java | 46 --
.../processors/kafka/pubsub/PublisherLease.java | 310 ---------
.../processors/kafka/pubsub/PublisherPool.java | 117 ----
.../services/org.apache.nifi.processor.Processor | 18 -
.../additionalDetails.html | 143 ----
.../additionalDetails.html | 143 ----
.../additionalDetails.html | 144 -----
.../additionalDetails.html | 156 -----
.../processors/kafka/pubsub/ConsumeKafkaTest.java | 128 ----
.../processors/kafka/pubsub/ConsumerPoolTest.java | 233 -------
.../processors/kafka/pubsub/ITConsumeKafka.java | 135 ----
.../kafka/pubsub/KafkaProcessorUtilsTest.java | 41 --
.../kafka/pubsub/TestConsumeKafkaRecord_0_11.java | 224 -------
.../kafka/pubsub/TestInFlightMessageTracker.java | 88 ---
.../processors/kafka/pubsub/TestPublishKafka.java | 250 -------
.../kafka/pubsub/TestPublishKafkaRecord_0_11.java | 309 ---------
.../kafka/pubsub/TestPublisherLease.java | 288 ---------
.../processors/kafka/pubsub/TestPublisherPool.java | 67 --
.../kafka/pubsub/util/MockRecordParser.java | 105 ---
.../kafka/pubsub/util/MockRecordWriter.java | 128 ----
.../src/test/resources/log4j.properties | 21 -
.../src/test/resources/server.properties | 121 ----
.../src/test/resources/zookeeper.properties | 20 -
.../nifi-kafka-bundle/nifi-kafka-0-8-nar/pom.xml | 45 --
.../src/main/resources/META-INF/LICENSE | 323 ---------
.../src/main/resources/META-INF/NOTICE | 95 ---
.../nifi-kafka-0-8-processors/pom.xml | 100 ---
.../processors/kafka/AbstractKafkaProcessor.java | 146 -----
.../org/apache/nifi/processors/kafka/GetKafka.java | 485 --------------
.../nifi/processors/kafka/KafkaPublisher.java | 269 --------
.../apache/nifi/processors/kafka/KafkaUtils.java | 74 ---
.../apache/nifi/processors/kafka/Partitioners.java | 83 ---
.../nifi/processors/kafka/PublishingContext.java | 151 -----
.../org/apache/nifi/processors/kafka/PutKafka.java | 510 ---------------
.../services/org.apache.nifi.processor.Processor | 16 -
.../additionalDetails.html | 45 --
.../additionalDetails.html | 45 --
.../processors/kafka/GetKafkaIntegrationTests.java | 174 -----
.../nifi/processors/kafka/KafkaPublisherTest.java | 263 --------
.../apache/nifi/processors/kafka/PutKafkaTest.java | 286 --------
.../apache/nifi/processors/kafka/TestGetKafka.java | 140 ----
.../nifi/processors/kafka/test/EmbeddedKafka.java | 226 -------
.../kafka/test/EmbeddedKafkaProducerHelper.java | 110 ----
.../src/test/resources/log4j.properties | 21 -
.../src/test/resources/server.properties | 121 ----
.../src/test/resources/zookeeper.properties | 20 -
.../nifi-kafka-bundle/nifi-kafka-0-9-nar/pom.xml | 41 --
.../src/main/resources/META-INF/LICENSE | 323 ---------
.../src/main/resources/META-INF/NOTICE | 82 ---
.../nifi-kafka-0-9-processors/pom.xml | 115 ----
.../nifi/processors/kafka/pubsub/ConsumeKafka.java | 388 -----------
.../processors/kafka/pubsub/ConsumerLease.java | 455 -------------
.../nifi/processors/kafka/pubsub/ConsumerPool.java | 244 -------
.../kafka/pubsub/InFlightMessageTracker.java | 186 ------
.../kafka/pubsub/KafkaProcessorUtils.java | 272 --------
.../nifi/processors/kafka/pubsub/Partitioners.java | 62 --
.../nifi/processors/kafka/pubsub/PublishKafka.java | 397 ------------
.../processors/kafka/pubsub/PublishResult.java | 56 --
.../processors/kafka/pubsub/PublisherLease.java | 143 ----
.../processors/kafka/pubsub/PublisherPool.java | 98 ---
.../services/org.apache.nifi.processor.Processor | 16 -
.../additionalDetails.html | 33 -
.../additionalDetails.html | 47 --
.../processors/kafka/pubsub/ConsumeKafkaTest.java | 97 ---
.../processors/kafka/pubsub/ConsumerPoolTest.java | 224 -------
.../processors/kafka/pubsub/ITConsumeKafka.java | 150 -----
.../kafka/pubsub/TestInFlightMessageTracker.java | 87 ---
.../processors/kafka/pubsub/TestPublishKafka.java | 262 --------
.../kafka/pubsub/TestPublisherLease.java | 248 -------
.../processors/kafka/pubsub/TestPublisherPool.java | 68 --
.../nifi/processors/kafka/test/EmbeddedKafka.java | 226 -------
.../src/test/resources/log4j.properties | 21 -
.../src/test/resources/server.properties | 121 ----
.../src/test/resources/zookeeper.properties | 20 -
nifi-nar-bundles/nifi-kafka-bundle/pom.xml | 32 -
125 files changed, 22460 deletions(-)
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-nar/pom.xml
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-nar/src/main/resources/META-INF/LICENSE
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-nar/src/main/resources/META-INF/NOTICE
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/pom.xml
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaRecord_0_10.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_0_10.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerPool.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/InFlightMessageTracker.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/KafkaProcessorUtils.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/Partitioners.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_0_10.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_0_10.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishResult.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherLease.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherPool.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/resources/META-INF/services/org.apache.nifi.processor.Processor
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_0_10/additionalDetails.html
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_0_10/additionalDetails.html
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_0_10/additionalDetails.html
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_10/additionalDetails.html
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumerPoolTest.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ITConsumeKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestConsumeKafkaRecord_0_10.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestInFlightMessageTracker.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublishKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublishKafkaRecord_0_10.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublisherLease.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublisherPool.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/util/MockRecordParser.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/util/MockRecordWriter.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/java/org/apache/nifi/processors/kafka/test/EmbeddedKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/resources/log4j.properties
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/resources/server.properties
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/test/resources/zookeeper.properties
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-nar/pom.xml
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-nar/src/main/resources/META-INF/LICENSE
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-nar/src/main/resources/META-INF/NOTICE
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/pom.xml
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaRecord_0_11.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_0_11.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerPool.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/InFlightMessageTracker.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/KafkaProcessorUtils.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/Partitioners.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafkaRecord_0_11.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka_0_11.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishResult.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherLease.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherPool.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/resources/META-INF/services/org.apache.nifi.processor.Processor
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.ConsumeKafkaRecord_0_11/additionalDetails.html
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_0_11/additionalDetails.html
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_0_11/additionalDetails.html
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_11/additionalDetails.html
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumerPoolTest.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ITConsumeKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/KafkaProcessorUtilsTest.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestConsumeKafkaRecord_0_11.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestInFlightMessageTracker.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublishKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublishKafkaRecord_0_11.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublisherLease.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublisherPool.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/util/MockRecordParser.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/util/MockRecordWriter.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/resources/log4j.properties
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/resources/server.properties
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-11-processors/src/test/resources/zookeeper.properties
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-nar/pom.xml
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-nar/src/main/resources/META-INF/LICENSE
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-nar/src/main/resources/META-INF/NOTICE
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/pom.xml
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/AbstractKafkaProcessor.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/KafkaPublisher.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/KafkaUtils.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/Partitioners.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/PublishingContext.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/resources/META-INF/services/org.apache.nifi.processor.Processor
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.GetKafka/additionalDetails.html
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.PutKafka/additionalDetails.html
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/java/org/apache/nifi/processors/kafka/GetKafkaIntegrationTests.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/java/org/apache/nifi/processors/kafka/KafkaPublisherTest.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/java/org/apache/nifi/processors/kafka/PutKafkaTest.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/java/org/apache/nifi/processors/kafka/TestGetKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/java/org/apache/nifi/processors/kafka/test/EmbeddedKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/java/org/apache/nifi/processors/kafka/test/EmbeddedKafkaProducerHelper.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/resources/log4j.properties
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/resources/server.properties
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/resources/zookeeper.properties
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-nar/pom.xml
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-nar/src/main/resources/META-INF/LICENSE
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-nar/src/main/resources/META-INF/NOTICE
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/pom.xml
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerPool.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/InFlightMessageTracker.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/KafkaProcessorUtils.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/Partitioners.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishResult.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherLease.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublisherPool.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/resources/META-INF/services/org.apache.nifi.processor.Processor
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.ConsumeKafka/additionalDetails.html
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/resources/docs/org.apache.nifi.processors.kafka.pubsub.PublishKafka/additionalDetails.html
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafkaTest.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ConsumerPoolTest.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/ITConsumeKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestInFlightMessageTracker.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublishKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublisherLease.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublisherPool.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/java/org/apache/nifi/processors/kafka/test/EmbeddedKafka.java
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/resources/log4j.properties
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/resources/server.properties
delete mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/test/resources/zookeeper.properties