You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2018/02/03 00:35:00 UTC
[jira] [Commented] (KAFKA-6454) Allow timestamp manipulation in
Processor API
[ 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:
users@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)