kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Damian Guy (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (KAFKA-4394) Processor API does not receive timestamp and/or ConsumerRecord
Date Wed, 09 Nov 2016 15:28:58 GMT

    [ https://issues.apache.org/jira/browse/KAFKA-4394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15651233#comment-15651233

Damian Guy commented on KAFKA-4394:

The record timestamp is available via {{ProcessorContext.timestamp()}}. The {{ProcessorContext}}
is supplied during {{init}} and is saved as the field {{context}} in {{AbstractProcessor}}

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

View raw message