Pawel Niezgoda created NIFI-4487:
------------------------------------
Summary: ConsumerKafka V10&V11 should write Kafka Timestamp
attribute
Key: NIFI-4487
URL: https://issues.apache.org/jira/browse/NIFI-4487
Project: Apache NiFi
Issue Type: Improvement
Components: Extensions
Affects Versions: 1.4.0, 1.5.0
Reporter: Pawel Niezgoda
Fix For: 1.5.0, 1.4.0
Starting from kafka v10 kafka provides info about message timestamp.
We should expose that data together with other attributes (like topic,
partition, offset).
We should add:
@WritesAttribute(attribute = KafkaProcessorUtils.KAFKA_TIMESTAMP, description =
"Kafka message timestamp"),
@WritesAttribute(attribute = KafkaProcessorUtils.KAFKA_TIMESTAMP_TYPE,
description = "Kafka message timestamp type")
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
