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

Scala API Wrapper for Streams uses default serializer for table aggregate

    XMLWordPrintableJSON

    Details

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

      Description

      On of the goals of the Scala API is to not fall back on the configured default serializer, but let the compiler provide them through implicits.

      The aggregate method on KGroupedStream misses to achieve this goal.

      Compared to the Java API is this behavior very supprising, because no other stream operation falls back to the default serializer and a developer assums, that the compiler checks for the correct serializer type.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                DannyNullZwo Daniel Heinrich
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: