Elias Levy created KAFKA-4144: --------------------------------- Summary: Allow per stream/table timestamp extractor Key: KAFKA-4144 URL: https://issues.apache.org/jira/browse/KAFKA-4144 Project: Kafka Issue Type: Improvement Components: streams Affects Versions: 0.10.0.1 Reporter: Elias Levy Assignee: Guozhang Wang
At the moment the timestamp extractor is configured via a StreamConfig value to KafkaStreams. That means you can only have a single timestamp extractor per app, even though you may be joining multiple streams/tables that require different timestamp extraction methods. You should be able to specify a timestamp extractor via KStreamBuilder.stream/table, just like you can specify key and value serdes that override the StreamConfig defaults. -- This message was sent by Atlassian JIRA (v6.3.4#6332)