You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Hashan Gayasri Udugahapattuwa (JIRA)" <ji...@apache.org> on 2018/08/03 04:46:00 UTC
[jira] [Resolved] (KAFKA-7233) InMemoryKeyValueStore is not
thread-safe for Interactive Queries
[ https://issues.apache.org/jira/browse/KAFKA-7233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Hashan Gayasri Udugahapattuwa resolved KAFKA-7233.
--------------------------------------------------
Resolution: Invalid
The implementation is correct
> InMemoryKeyValueStore is not thread-safe for Interactive Queries
> ----------------------------------------------------------------
>
> Key: KAFKA-7233
> URL: https://issues.apache.org/jira/browse/KAFKA-7233
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 1.1.0, 2.0.0
> Environment: Fedora 27
> Reporter: Hashan Gayasri Udugahapattuwa
> Priority: Critical
>
> When querying externally from via the [ReadOnlyKeyValueStore|https://github.com/apache/kafka/blob/1.0/streams/src/main/java/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.java] API (Interactive Queries), the InMemoryKeyValueStore does not protect its internal map from concurrent reads and writes which may produce incorrect results to the ReadOnlyKeyValueStore API. Note that reads(query thread) and writes(stream thread) can happen concurrently.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)