Matthias J. Sax created KAFKA-4785:
--------------------------------------
Summary: Records from internal repartitioning topics should always
use RecordMetadataTimestampExtractor
Key: KAFKA-4785
URL: https://issues.apache.org/jira/browse/KAFKA-4785
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 0.10.2.0
Reporter: Matthias J. Sax
Users can specify what timestamp extractor should be used to decode the
timestamp of input topic records. As long as RecordMetadataTimestamp or
WallclockTime is use this is fine.
However, for custom timestamp extractors it might be invalid to apply this
custom extractor to records received from internal repartitioning topics. The
reason is that Streams sets the current "stream time" as record metadata
timestamp explicitly before writing to intermediate repartitioning topics
because this timestamp should be use by downstream subtopologies. A custom
timestamp extractor might return something different breaking this assumption.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
