[
https://issues.apache.org/jira/browse/KAFKA-8888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16927855#comment-16927855
]
Guozhang Wang commented on KAFKA-8888:
--------------------------------------
Just to clarify, the common usage pattern is
{code}
Store store = streams.store(...);
store.get(...)
{code}
In the first line, we would check if there are any stores for the given store
name in the current assigned tasks across all threads already and throw
TaskMigratedException when possible., but that would pass as long as at least
one task containing the corresponding store name is in one of the threads.
So in the `get` call, we should probably do another check similar to
`metadataForKey` and throw TaskMigratedException as well.
> Possible to get null IQ value if reading from wrong instance
> ------------------------------------------------------------
>
> Key: KAFKA-8888
> URL: https://issues.apache.org/jira/browse/KAFKA-8888
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Chris Pettitt
> Priority: Minor
>
> Currently if you try to read a key from the wrong instance (i.e. the
> partition that the key is mapped to is owned by a different instance) you get
> null and no indication you're reading from the wrong instance. It would be
> nice to get some indication that the instance is the wrong instance and not
> that the value for the key is null.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
