Hashan Gayasri Udugahapattuwa created KAFKA-7233:
----------------------------------------------------
Summary: 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: 2.0.0, 1.1.0
Environment: Fedora 27
Reporter: Hashan Gayasri Udugahapattuwa
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)
