kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Hashan Gayasri Udugahapattuwa (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-7233) InMemoryKeyValueStore is not thread-safe for Interactive Queries
Date Thu, 02 Aug 2018 04:55:00 GMT
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

View raw message