[jira] [Created] (KAFKA-4532) StateStores can be connected to the wrong source topic

["Damian Guy (JIRA)" <ji...@apache.org>]

Damian Guy created KAFKA-4532:
---------------------------------

             Summary: StateStores can be connected to the wrong source topic
                 Key: KAFKA-4532
                 URL: https://issues.apache.org/jira/browse/KAFKA-4532
             Project: Kafka
          Issue Type: Bug
          Components: streams
    Affects Versions: 0.10.1.0, 0.10.1.1, 0.10.2.0
            Reporter: Damian Guy
            Assignee: Damian Guy
             Fix For: 0.10.2.0


When building a topology with tables and StateStores, the StateStores are mapped to the source topic names. This map is retrieved via {{TopologyBuilder.stateStoreNameToSourceTopics()}} and is used in Interactive Queries to find the source topics and partitions when resolving the partitions that particular keys will be in.

There is an issue where by this mapping for a table that is originally created with {{builder.table("topic", "table");}}, and then is subsequently used in a join, is changed to the join topic. This is because the mapping is updated during the call to {{topology.connectProcessorAndStateStores(..)}}. 

In the case that the {{stateStoreNameToSourceTopics}} Map already has a value for the state store name it should not update the Map.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)