kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bruno Cadonna (Jira)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-10179) State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables
Date Wed, 17 Jun 2020 15:37:00 GMT
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)

Mime
View raw message