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)
