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)
