[
https://issues.apache.org/jira/browse/NIFI-6947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matt Burgess reassigned NIFI-6947:
----------------------------------
Assignee: Matt Burgess
> 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
>
> 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)
