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)
