[KAFKA-4532] StateStores can be connected to the wrong source topic resulting in incorrect metadata returned from IQ

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.10.1.0, 0.10.1.1, 0.10.2.0
• Fix Version/s: 0.10.2.0
• Component/s: streams
• Assignee: Damian Guy
• Reporter: Damian Guy
• Created: 13/Dec/16 15:41
• Updated: 13/Dec/16 20:37
• Resolved: 13/Dec/16 20:35

Description

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.

Issue Links

• links to: GitHub Pull Request #2250