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)
