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)