You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@nifi.apache.org by "David Handermann (Jira)" <ji...@apache.org> on 2025/08/05 18:30:00 UTC
[jira] [Created] (NIFI-14822) Add Inject Offset Output Strategy to ConsumeKafka
David Handermann created NIFI-14822:
---------------------------------------
Summary: 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
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)