You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Mark Shelton (JIRA)" <ji...@apache.org> on 2016/11/10 19:37:58 UTC

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

     [ https://issues.apache.org/jira/browse/KAFKA-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Mark Shelton resolved KAFKA-4394.
---------------------------------
    Resolution: Not A Problem

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