Bruno Cadonna created KAFKA-10179:
-------------------------------------
Summary: State Store Passes Wrong Changelog Topic to Serde for
Optimized Source Tables
Key: KAFKA-10179
URL: https://issues.apache.org/jira/browse/KAFKA-10179
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 2.5.0
Reporter: Bruno Cadonna
Fix For: 2.7.0
{{MeteredKeyValueStore}} passes the name of the changelog topic of the state
store to the state store serdes. Currently, it always passes {{<application
ID>-<store name>-changelog}} as the changelog topic name. However, for
optimized source tables the changelog topic is the source topic.
Most serdes do not use the topic name passed to them. However, if the serdes
actually use the topic name for (de)serialization, e.g., when Kafka Streams is
used with Confluent's Schema Registry, a
{{org.apache.kafka.common.errors.SerializationException}} is thrown.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
