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 dd8b87f6f9 NIFI-14550 Allow setting version control info on a
non-versioned process group - Update stopVersionControl to no longer clear
versioned component ids in order to allow re-attaching later - Add new methods
to service facade and PG DAO to pass the flow snapshot when setting VCI - Fix
system test to ensure UP_TO_DATE after Set Version Info
add 847686684f NIFI-14566 Added Inject Metadata Output Strategy in
ConsumeKafka (#9942)
No new revisions were added by this update.
Summary of changes:
...ava => ConsumeKafkaInjectMetadataRecordIT.java} | 53 ++---
.../kafka/processors/ConsumeKafkaRecordIT.java | 38 ++--
.../processors/ConsumeKafkaWrapperRecordIT.java | 29 +--
.../apache/nifi/kafka/processors/ConsumeKafka.java | 10 +-
.../AbstractRecordStreamKafkaMessageConverter.java | 220 +++++++++++++++++++++
.../convert/RecordStreamKafkaMessageConverter.java | 170 ++--------------
.../WrapperRecordStreamKafkaMessageConverter.java | 173 +++-------------
.../consumer/wrapper/ConsumeWrapperRecord.java | 12 +-
.../consumer/wrapper/WrapperRecordKeyReader.java | 4 +-
...rapperRecord.java => InjectMetadataRecord.java} | 78 ++++++--
.../processors/producer/wrapper/WrapperRecord.java | 4 +-
.../additionalDetails.md | 177 +++++++++++++++++
...apperRecordStreamKafkaMessageConverterTest.java | 4 +-
.../nifi/kafka/shared/property/OutputStrategy.java | 4 +-
14 files changed, 597 insertions(+), 379 deletions(-)
copy
nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/{ConsumeKafkaWrapperRecordIT.java
=> ConsumeKafkaInjectMetadataRecordIT.java} (79%)
create mode 100644
nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/kafka/processors/consumer/convert/AbstractRecordStreamKafkaMessageConverter.java
copy
nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/kafka/processors/producer/wrapper/{WrapperRecord.java
=> InjectMetadataRecord.java} (51%)
create mode 100644
nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/resources/docs/org.apache.nifi.kafka.processors.ConsumeKafka/additionalDetails.md
