You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Ted Yu (JIRA)" <ji...@apache.org> on 2017/12/30 08:19:00 UTC

[jira] [Created] (KAFKA-6412) Improve synchronization in CachingKeyValueStore methods

Ted Yu created KAFKA-6412:
-----------------------------

             Summary: Improve synchronization in CachingKeyValueStore methods
                 Key: KAFKA-6412
                 URL: https://issues.apache.org/jira/browse/KAFKA-6412
             Project: Kafka
          Issue Type: Improvement
            Reporter: Ted Yu


Currently CachingKeyValueStore methods are synchronized at method level.

It seems we can use read lock for getter and write lock for put / delete methods.

For getInternal(), if the underlying thread is streamThread, the getInternal() may trigger eviction. This can be handled by obtaining write lock at the beginning of the method for streamThread.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)