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)