Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-10179

State Store Passes Wrong Changelog Topic to Serde for Optimized Source Tables

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.5.0
    • Fix Version/s: 2.7.0
    • Component/s: streams
    • Labels:
      None

      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

            Activity

              People

              • Assignee:
                cadonna Bruno Cadonna
                Reporter:
                cadonna Bruno Cadonna
              • Votes:
                0 Vote for this issue
                Watchers:
                8 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: