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

StreamBuilder#table and StreamsBuilder#globalTable should use serdes from Materialized

    XMLWordPrintableJSON

    Details

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

      Description

      The new overloads StreamBuilder.table(String, Materialized) and StreamsBuilder.globalTable(String, Materialized) need to set the serdes from Materialized on the internal Consumed instance that is created, otherwise the defaults will be used and may result in serialization errors

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                damianguy Damian Guy
                Reporter:
                damianguy Damian Guy
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: