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

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

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 2.2.0, 2.3.0, 2.2.1, 2.2.2, 2.4.0, 2.3.1, 2.4.1
    • 2.2.3, 2.3.2, 2.6.0, 2.4.2, 2.5.1
    • streams
    • 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

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

            Dates

              Created:
              Updated:
              Resolved: