Almog Gavra created KAFKA-16046: ----------------------------------- Summary: Stream Stream Joins fail after restoration with deserialization exceptions Key: KAFKA-16046 URL: https://issues.apache.org/jira/browse/KAFKA-16046 Project: Kafka Issue Type: Bug Affects Versions: 3.7.0 Reporter: Almog Gavra Assignee: Almog Gavra
Before KIP-954, the `KStreamImplJoin` class would always create non-timestamped persistent windowed stores. After that KIP, the default was changed to create timestamped stores. This wasn't compatible because, during restoration, timestamped stores have their changelog values transformed to prepend the timestamp to the value. This caused serialization errors when trying to read from the store because the deserializers did not expect the timestamp to be prepended. -- This message was sent by Atlassian Jira (v8.20.10#820010)