Description
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.
Attachments
Issue Links
- is related to
-
KAFKA-10252 MeteredTimestampedKeyValueStore not setting up correct topic name for GlobalKTable associating StateStores
-
- Patch Available
-
- links to