[jira] [Commented] (KAFKA-6453) Reconsider timestamp propagation semantics

["Victoria Bialas (Jira)" <ji...@apache.org>]

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

Victoria Bialas commented on KAFKA-6453:
----------------------------------------

Hi [~mjsax], I tried to re-assign this to James Galasyn who is covering Streams Docs now, but he doesn't come up as an option to reassign. I'll forward the link to this to him on Slack, and you guys can figure out how to reassign. (Otherwise this will be perennially relegated to the back burner.)

> Reconsider timestamp propagation semantics
> ------------------------------------------
>
>                 Key: KAFKA-6453
>                 URL: https://issues.apache.org/jira/browse/KAFKA-6453
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>            Reporter: Matthias J. Sax
>            Priority: Major
>              Labels: needs-kip
>
> 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.
> The DSL, inherits this "contract" atm.
> From a DSL point of view, it would be desirable to provide a different contract to the user. To allow this, we need to do the following:
>  - extend Processor API to allow manipulation timestamps (ie, a Processor can set a new timestamp for downstream records)
>  - define a DSL "contract" for timestamp propagation for each DSL operator
>  - document the DSL "contract"
>  - implement the DSL "contract" using the new/extended Processor API



--
This message was sent by Atlassian Jira
(v8.3.4#803005)