[
https://issues.apache.org/jira/browse/KAFKA-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Damian Guy updated KAFKA-4532:
------------------------------
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.
was:
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 is also effects Interactive Queries. The metadata returned when trying to
find the instance for a key from the source table is incorrect as the store
name is mapped to the incorrect topic.
> StateStores can be connected to the wrong source topic resulting in incorrect
> metadata returned from IQ
> -------------------------------------------------------------------------------------------------------
>
> 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)
