This is an automated email from the ASF dual-hosted git repository.
greyp pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
from 1ae31c39ed NIFI-14117 PublishKafka sends default attribute as key if
custom attribute not specified (#9608)
add aa66b57c95 NIFI-14123: support kafka tombstone with USE_WRAPPER
strategy
add a53dc6e79d NIFI-14123: update processor description
add 3f8805d5cb NIFI-14122 / NIFI-14123: Add support for kafka.tombstones
again
add a500157a76 NIFI-14122: fix checkstyle violations
add 6bee090b69 NIFI-14123: Refactor kafka tombstone integration tests
new 34dad3443d Merge pull request #9604 from babubabu/NIFI-14123
The 1 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:
...meKafkaIT.java => ConsumeKafkaTombstoneIT.java} | 62 ++--------------------
...shKafkaIT.java => PublishKafkaTombstoneIT.java} | 9 ++--
...a => PublishKafkaWrapperRecordTombstoneIT.java} | 21 +++-----
.../processors/publish/ffwrapper-tombstone.json | 21 ++++++++
.../service/consumer/Kafka3ConsumerService.java | 8 ++-
.../apache/nifi/kafka/processors/PublishKafka.java | 3 +-
.../FlowFileStreamKafkaMessageConverter.java | 8 ++-
.../FlowFileStreamKafkaRecordConverter.java | 11 ++--
.../RecordWrapperStreamKafkaRecordConverter.java | 5 +-
9 files changed, 67 insertions(+), 81 deletions(-)
copy
nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/{ConsumeKafkaIT.java
=> ConsumeKafkaTombstoneIT.java} (64%)
copy
nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/{PublishKafkaIT.java
=> PublishKafkaTombstoneIT.java} (90%)
copy
nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/java/org/apache/nifi/kafka/processors/{PublishKafkaWrapperRecordIT.java
=> PublishKafkaWrapperRecordTombstoneIT.java} (84%)
create mode 100644
nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-3-integration/src/test/resources/org/apache/nifi/kafka/processors/publish/ffwrapper-tombstone.json
