You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@nifi.apache.org by "Pierre Villard (Jira)" <ji...@apache.org> on 2026/02/13 14:08:00 UTC

[jira] [Resolved] (NIFI-15591) Add kafka.timestamp attribute in ConsumeKafka for flow files emitted using ProcessingStrategy.RECORD

     [ https://issues.apache.org/jira/browse/NIFI-15591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Pierre Villard resolved NIFI-15591.
-----------------------------------
    Fix Version/s: 2.9.0
       Resolution: Fixed

> 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
>            Priority: Major
>             Fix For: 2.9.0
>
>          Time Spent: 50m
>  Remaining Estimate: 0h
>
>  
> 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)