[jira] [Created] (NIFI-6947) Add PutRecord processor to leverage RecordSinkService implementations

["Matt Burgess (Jira)" <ji...@apache.org>]

Matt Burgess created NIFI-6947:
----------------------------------

             Summary: Add PutRecord processor to leverage RecordSinkService implementations
                 Key: NIFI-6947
                 URL: https://issues.apache.org/jira/browse/NIFI-6947
             Project: Apache NiFi
          Issue Type: New Feature
          Components: Extensions
            Reporter: Matt Burgess


The RecordSinkService interface was created as part of NIFI-6780 in order to decouple the generation of status records (via QueryNiFiReportingTask for example) from the transport/format of an external system. Implementations such as SiteToSiteReportingRecordSink, DatabaseRecordSink, and KafkaRecordSink are already in NiFi.

This Jira proposes a generic PutRecord processor that consists of RecordReader and  RecordSinkService controller services, for the purposes of sending the records of an incoming flow file to whatever RecordSinkService implementation is configured by the user. In general this might alleviate the need for "PutExternalSystemXRecord" processors such as PutDatabaseRecord, where a single processor type can be used to send records to any number of external systems for which a RecordSinkService has been implemented. It basically shifts the logic from the processor to the controller service, but if a RecordSinkServiceLookup is implemented, this could offer a more flexible approach to sending records to various systems with fewer components.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)