[NIFI-4487] ConsumerKafka V10&V11 should write Kafka Timestamp attribute

• Type: Improvement
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.4.0, 1.5.0
• Component/s: Extensions
• Assignee: Unassigned
• Reporter: Pawel Niezgoda
• Created: 16/Oct/17 07:52
• Updated: 12/Jan/18 23:24

Description

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")