[jira] [Created] (KAFKA-4394) Processor API does not receive timestamp and/or ConsumerRecord

["Mark Shelton (JIRA)" <ji...@apache.org>]

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)