[
https://issues.apache.org/jira/browse/NIFI-14822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18012335#comment-18012335
]
ASF subversion and git services commented on NIFI-14822:
--------------------------------------------------------
Commit 52bffaddf84add6e420581fa9ee641d5efdaa983 in nifi's branch
refs/heads/main from David Handermann
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=52bffaddf8 ]
NIFI-14822 Added Inject Offset Output Strategy to ConsumeKafka
Signed-off-by: Pierre Villard <[email protected]>
This closes #10171.
> Add Inject Offset Output Strategy to ConsumeKafka
> -------------------------------------------------
>
> Key: NIFI-14822
> URL: https://issues.apache.org/jira/browse/NIFI-14822
> Project: Apache NiFi
> Issue Type: Improvement
> Reporter: David Handermann
> Assignee: David Handermann
> Priority: Major
> Time Spent: 0.5h
> Remaining Estimate: 0h
>
> A new {{Output Strategy}} value should be added to the {{ConsumeKafka}}
> Processor supporting the option to inject the Kafka record offset as a single
> field named {{kafkaOffset}}.
> This new option is similar to the {{Inject Metadata}} option, but limits
> record field changes to the offset, avoiding the introduction of other
> metadata fields. This strategy supports use cases with high volumes that
> require the Kafka record offset for tracking, but do not need any additional
> metadata, which is otherwise available as FlowFile attributes for batches of
> records.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
