You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Matthias J. Sax (JIRA)" <ji...@apache.org> on 2018/01/16 18:27:00 UTC

[jira] [Created] (KAFKA-6454) Allow timestamp manipulation in Processor API

Matthias J. Sax created KAFKA-6454:
--------------------------------------

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


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.



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