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

["ASF subversion and git services (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/NIFI-6947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17010465#comment-17010465 ] 

ASF subversion and git services commented on NIFI-6947:
-------------------------------------------------------

Commit c604923c0b20533299cbc2fa7e88dbfc0d790f80 in nifi's branch refs/heads/master from Matt Burgess
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=c604923 ]

NIFI-6947: Add PutRecord processor using RecordSinkService (#3943)

* NIFI-6947: Add PutRecord processor using RecordSinkService

* NIFI-6947: Incorporated review comments


> 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
>            Assignee: Matt Burgess
>            Priority: Major
>          Time Spent: 1h
>  Remaining Estimate: 0h
>
> 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)