Adam Bellemare created KAFKA-7552:
-------------------------------------
Summary: StatefulProcessorNode tries to connect state store to
processor before it is added
Key: KAFKA-7552
URL: https://issues.apache.org/jira/browse/KAFKA-7552
Project: Kafka
Issue Type: Bug
Components: streams
Affects Versions: 2.0.0, 2.1.0
Reporter: Adam Bellemare
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."
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
