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

StatefulProcessorNode tries to connect state store to processor before it is added

    XMLWordPrintableJSON

    Details

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

      Description

      StatefulProcessorNode tries to "connectProcessorAndStateStores" before "addStateStore" is called on the state store. This throws an exception. Current implementations of Kafka Streams do not appear to test for this, nor do any of the kafka streams applications use it. Discovered while looking to use the node for another ticket.

      https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StatefulProcessorNode.java#L86

       

      Results in "org.apache.kafka.streams.errors.TopologyException: Invalid topology: StateStore <statestore-name> is not added yet."

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              abellemare Adam Bellemare
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: