nifi-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mika Borner <>
Subject Re: PublishKafka setting record timestamp
Date Thu, 01 Feb 2018 06:30:02 GMT
Thanks Bryan

For PublishKafka, couldn't this be done by using an attribute that 
contains the timestamp?

For PublishKafkaRecord this sounds reasonable.

I guess, I will open an enhancement request then.


On 01/30/2018 02:58 PM, Bryan Bende wrote:
> Hello,
> The timestamp in Kafka is separate from the headers, currently there
> isn't a way to specify the timestamp from NiFi.
> For PublishKafkaRecord, I could see having an option to take the value
> of a specified field from each record and make that the timestamp,
> assuming it can be converted to a long.
> For PublishKafka, the processor doesn't have any knowledge about the
> actual data, so the only thing that could be done here is to set the
> same timestamp for every piece of data from the given flow file, which
> doesn't seem as helpful.
> -Bryan
> On Mon, Jan 29, 2018 at 5:37 AM, Mika Borner <> wrote:
>> Hi,
>> Is it possible to set the producer record timestamp within the
>> PublishKafka_1_0 / PublishKafkaRecord_1_0 processor?
>> I tried to use the "Attributes to Send as Headers" option with a timestamp
>> attribute, but this did not work. Not sure if the timestamp producer
>> record's timestamp is in the headers.
>> Appreciate any help.
>> Thanks,
>> Mika>

View raw message