[
https://issues.apache.org/jira/browse/NIFI-14822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Handermann updated NIFI-14822:
------------------------------------
Status: Patch Available (was: In Progress)
> 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: 10m
> 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)
