[nifi] branch main updated (9e3987d04e -> 30facedc43)

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

markap14 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


    from 9e3987d04e NIFI-10826 Separated Maven Compile and Verify in ci-workflow
     add 30facedc43 NIFI-9822 - ConsumeKafkaRecord allows writing out Kafka record key (#6131)

No new revisions were added by this update.

Summary of changes:
 .../nifi-kafka-2-6-processors/pom.xml              |  12 +
 .../kafka/pubsub/ConsumeKafkaRecord_2_6.java       |  58 +-
 .../processors/kafka/pubsub/ConsumerLease.java     | 208 +++--
 .../nifi/processors/kafka/pubsub/ConsumerPool.java |  28 +-
 .../kafka/pubsub/KafkaProcessorUtils.java          |  12 +
 .../processors/kafka/pubsub/OutputStrategy.java    |  25 +
 .../kafka/pubsub/PublishKafkaRecord_2_6.java       |  53 +-
 .../processors/kafka/pubsub/PublishKafka_2_6.java  |   3 +-
 .../kafka/pubsub/PublishMetadataStrategy.java      |  23 +
 .../processors/kafka/pubsub/PublishStrategy.java   |  25 +
 .../processors/kafka/pubsub/PublisherLease.java    | 226 +++++-
 .../processors/kafka/pubsub/PublisherPool.java     |  11 +-
 .../additionalDetails.html                         | 127 +++
 .../additionalDetails.html                         | 883 +++++++++++++++++++++
 .../kafka/pubsub/TestConsumeKafkaMock.java         | 517 ++++++++++++
 .../pubsub/TestConsumeKafkaRecordKey_2_6.java      | 103 +++
 .../kafka/pubsub/TestPublishKafkaMock.java         | 372 +++++++++
 .../pubsub/TestPublishKafkaMockParameterized.java  | 289 +++++++
 .../pubsub/TestPublishKafkaRecordKey_2_6.java      | 102 +++
 .../kafka/pubsub/TestPublishKafkaRecord_2_6.java   |  26 +-
 .../kafka/pubsub/TestPublisherLease.java           |   4 +-
 .../processors/kafka/pubsub/TestPublisherPool.java |   4 +-
 .../parameterized/flowfileInput1.json              |   8 +
 .../parameterized/flowfileInputA.json              |  12 +
 .../PublishRecord/parameterized/kafkaOutput1V.json |  21 +
 .../PublishRecord/parameterized/kafkaOutput1W.json |   5 +
 .../PublishRecord/parameterized/kafkaOutputAV.json |  24 +
 .../PublishRecord/parameterized/kafkaOutputAW.json |  13 +
 28 files changed, 3091 insertions(+), 103 deletions(-)
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/OutputStrategy.java
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishMetadataStrategy.java
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/PublishStrategy.java
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestConsumeKafkaMock.java
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestConsumeKafkaRecordKey_2_6.java
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublishKafkaMock.java
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublishKafkaMockParameterized.java
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/TestPublishKafkaRecordKey_2_6.java
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/PublishRecord/parameterized/flowfileInput1.json
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/PublishRecord/parameterized/flowfileInputA.json
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/PublishRecord/parameterized/kafkaOutput1V.json
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/PublishRecord/parameterized/kafkaOutput1W.json
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/PublishRecord/parameterized/kafkaOutputAV.json
 create mode 100644 nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/PublishRecord/parameterized/kafkaOutputAW.json