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

ASF GitHub Bot commented on KAFKA-6454:
---------------------------------------

mjsax opened a new pull request #4519: KAFKA-6454: Allow timestamp manipulation 
in Processor API
URL: https://github.com/apache/kafka/pull/4519
 
 
   implements KIP-251
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


> Allow timestamp manipulation in Processor API
> ---------------------------------------------
>
>                 Key: KAFKA-6454
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6454
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>    Affects Versions: 1.0.0
>            Reporter: Matthias J. Sax
>            Assignee: Matthias J. Sax
>            Priority: Major
>              Labels: kip
>             Fix For: 1.2.0
>
>
> Atm, Kafka Streams only has a defined "contract" about timestamp propagation 
> at the Processor API level: all processor within a sub-topology, see the 
> timestamp from the input topic record and this timestamp will be used for all 
> result record when writing them to an topic, too.
> For the DSL and also for custom operator, it would be desirable to allow 
> timestamp manipulation for at Processor level for individual records that are 
> forwarded.
> KIP-251: 
> https://cwiki.apache.org/confluence/display/KAFKA/KIP-251%3A+Allow+timestamp+manipulation+in+Processor+API



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to