[
https://issues.apache.org/jira/browse/NIFI-6819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16967896#comment-16967896
]
ASF subversion and git services commented on NIFI-6819:
-------------------------------------------------------
Commit 442a80bf1bfc76d3937dbaefde471223bacbec52 in nifi's branch
refs/heads/master from Matt Burgess
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=442a80b ]
NIFI-6819: Add KafkaRecordSink implementations for Kafka 1 and 2 (#3854)
* NIFI-6819: Add KafkaRecordSink implementations for Kafka 1 and 2
* Updated version to 1.11, corrected doc, added cleanup code
> Add RecordSink implementation for Kafka publishing
> --------------------------------------------------
>
> Key: NIFI-6819
> URL: https://issues.apache.org/jira/browse/NIFI-6819
> Project: Apache NiFi
> Issue Type: New Feature
> Components: Extensions
> Reporter: Matt Burgess
> Assignee: Matt Burgess
> Priority: Major
> Time Spent: 1h 40m
> Remaining Estimate: 0h
>
> 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.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
