[KAFKA-6454] Allow timestamp manipulation in Processor API

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 2.0.0
• Component/s: streams
• Labels: kip
• Assignee: Matthias J. Sax
• Reporter: Matthias J. Sax
• Created: 16/Jan/18 18:26
• Updated: 01/Dec/18 19:07
• Resolved: 16/Mar/18 23:02

Description

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.

KIP-251: https://cwiki.apache.org/confluence/display/KAFKA/KIP-251%3A+Allow+timestamp+manipulation+in+Processor+API

Issue Links

• blocks: KAFKA-6455 Improve timestamp propagation at DSL level
• duplicates: KAFKA-4219 Permit setting of event time in stream processor
• is a child of: KAFKA-6453 Document timestamp propagation semantics
• links to: GitHub Pull Request #4519
• mentioned in: Page Loading...
• mentioned in: Page Loading...