Mark Shelton created KAFKA-4394:
-----------------------------------
Summary: Processor API does not receive timestamp and/or
ConsumerRecord
Key: KAFKA-4394
URL: https://issues.apache.org/jira/browse/KAFKA-4394
Project: Kafka
Issue Type: Improvement
Components: streams
Affects Versions: 0.10.0.1
Reporter: Mark Shelton
Assignee: Guozhang Wang
Priority: Critical
I'm trying to implement a custom low-level processor by implementing
org.apache.kafka.streams.processor.Processor or AbstractProcessor.
The "process(K key, V value)" process method only receives the key and value
and does not provide access to timestamp or other information from
ConsumerRecord. It is critical for me to get access to the message timestamp.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
