Lukas Kucharski created NIFI-15591:
--------------------------------------
Summary: Add kafka.timestamp attribute in ConsumeKafka for flow
files emitted using ProcessingStrategy.RECORD
Key: NIFI-15591
URL: https://issues.apache.org/jira/browse/NIFI-15591
Project: Apache NiFi
Issue Type: Improvement
Components: Extensions
Reporter: Lukas Kucharski
Assignee: Lukas Kucharski
We're missing *kafka.timestamp* attribute in FF emitted from *ConsumeKafka*
when the processing strategy is set to *RECORD.*
The *kafka.timestamp* attribute is set for *FLOW_FILE strategy, DEMARCATOR
strategy* (set to the timestamp from the first record in a batch), but is not
set for *RECORD* strategy
This change will add the missing *kafka.timestamp* attribute.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
