In Kafka Streams, all records must have a valid timestamp. If you
process data from a topic that was written prior to 0.10, those messages
do not have an embedded message timestamp (which is the default
timestamp used by Kafka Streams).
To fix this issue, you need to provide a different timestamp extractor, via
streamsConfig(StreamsConfig.TIMESTAMP_EXTRACTOR_CLASS_CONFIG,
"package.and.name.of.extractor");
If you messaged have a useful timestamp in the data themselves, you
should provide a custom extractor. If your data does not have a useful
timestamp, you can fall back to WallclockTimestampExtractor (however,
getting different time semantic with this)
See
http://docs.confluent.io/3.0.1/streams/concepts.html#time for
further details.
-Matthias
> --
> You received this message because you are subscribed to the Google
> Groups "Confluent Platform" group.
> To unsubscribe from this group and stop receiving emails from it, send
> an email to
confluent-platf...@googlegroups.com
> <mailto:
confluent-platf...@googlegroups.com>.
> To post to this group, send email to
confluent...@googlegroups.com
> <mailto:
confluent...@googlegroups.com>.
> <
https://groups.google.com/d/msgid/confluent-platform/49e9ea06-371d-4d6d-b355-e6a4587dae9e%40googlegroups.com?utm_medium=email&utm_source=footer>.