You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Bill Bejeck (JIRA)" <ji...@apache.org> on 2018/10/27 23:38:00 UTC
[jira] [Resolved] (KAFKA-7552) StatefulProcessorNode tries to
connect state store to processor before it is added
[ https://issues.apache.org/jira/browse/KAFKA-7552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Bill Bejeck resolved KAFKA-7552.
--------------------------------
Resolution: Fixed
Fixed with PR [https://github.com/apache/kafka/pull/5740|https://github.com/apache/kafka/pull/5740.]
> 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
> Priority: Minor
>
> 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)