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

StreamsBuilder.build fails with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode"

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 2.2.0, 2.3.0, 2.2.1, 2.2.2, 2.4.0, 2.3.1, 2.4.1
    • Fix Version/s: 2.2.3, 2.3.2, 2.6.0, 2.4.2, 2.5.1
    • Component/s: streams
    • Labels:
      None

      Description

      We created a topology using Streams DSL (topology description is available in the attached topology-description.txt, no optimization).

      Topology works fine with topology.optimization=none, however it fails to build with StreamsException "Found a null keyChangingChild node for OptimizableRepartitionNode" if we set topology.optimization=all (exception stack trace is attached streams-exception-log.txt).

      We used https://zz85.github.io/kafka-streams-viz/ to visualize topology and try to guess what might be upsetting optimizer, yet did not manage to figure it out ourselves.

        Attachments

        1. topology-description.txt
          5 kB
          Artur Poliachenko
        2. streams-exception-log.txt
          7 kB
          Artur Poliachenko
        3. topology-definition-fragment.java
          7 kB
          Artur Poliachenko

          Activity

            People

            • Assignee:
              bbejeck Bill Bejeck
              Reporter:
              apoli Artur Poliachenko
            • Votes:
              1 Vote for this issue
              Watchers:
              7 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: