kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Adam Bellemare (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-7552) StatefulProcessorNode tries to connect state store to processor before it is added
Date Thu, 25 Oct 2018 18:21:00 GMT
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)

Mime
View raw message