This is an automated email from the ASF dual-hosted git repository. greyp pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/nifi.git
commit 34dad3443d0a0cfdd0ca1683b15d12ad1a7479ad Merge: 1ae31c39ed 6bee090b69 Author: greyp9 <[email protected]> AuthorDate: Tue Jan 7 12:06:56 2025 -0500 Merge pull request #9604 from babubabu/NIFI-14123 NIFI-14123: support kafka tombstone with USE_WRAPPER strategy .../kafka/processors/ConsumeKafkaTombstoneIT.java | 111 +++++++++++++++++++++ .../kafka/processors/PublishKafkaTombstoneIT.java | 83 +++++++++++++++ .../PublishKafkaWrapperRecordTombstoneIT.java | 104 +++++++++++++++++++ .../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, 347 insertions(+), 7 deletions(-)
