[
https://issues.apache.org/jira/browse/KAFKA-8065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-8065:
--------------------------------------
Assignee: Matthias J. Sax
> Forwarding modified timestamps does not reset timestamp correctly
> -----------------------------------------------------------------
>
> Key: KAFKA-8065
> URL: https://issues.apache.org/jira/browse/KAFKA-8065
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 2.0.1, 2.2.0, 2.1.1
> Reporter: Matthias J. Sax
> Assignee: Matthias J. Sax
> Priority: Major
> Fix For: 2.2.0, 2.0.2, 2.1.2
>
>
> Using Processor API, users can set a new output record timestamp via
> `context.forward(..., To.all().withTimestamp(...))`. However, after the
> forward()-call returns, the timestamp is not reset to the original input
> record timestamp and thus a consecutive call to `context.forward(...)`
> without `To` will use the newly set output record timestamp from before, too.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
