[NIFI-6819] Add RecordSink implementation for Kafka publishing

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Extensions
• Assignee: Matt Burgess
• Reporter: Matt Burgess
• Created: 29/Oct/19 03:36
• Updated: 05/Nov/19 21:57
• Resolved: 05/Nov/19 21:45

Description

With the advent of NIFI-6780, a RecordSinkService controller service interface is available and is used by components like QueryNiFiReportingTask to decouple the collection of data from its destination or transmission method. Initial implementations in NIFI-6780 included a Site-to-Site record sink as well as a DatabaseRecordSink for writing to RDBMS targets, and NIFI-6799 added a PrometheusRecordSink.

This Jira proposes to add a RecordSinkService implementation for publishing to Kafka. A RecordSetWriter property should be provided for formatting the data.

Issue Links

• links to: GitHub Pull Request #3854