Ki Lok Wong created KAFKA-12804:
-----------------------------------
Summary: In-Memory state store backed by InMemoryKeyValueStore is
slow due to synchronizing reads/writes using a single lock.
Key: KAFKA-12804
URL: https://issues.apache.org/jira/browse/KAFKA-12804
Project: Kafka
Issue Type: Improvement
Components: streams
Affects Versions: 2.6.2
Reporter: Ki Lok Wong
Default In-Memory state store (InMemoryKeyValueStore) uses TreeMap as the
backing map implementation. Read/write methods such as get() and put() are
synchronized on the same lock hence significantly reducing multi-thread
performance.
https://github.com/a0x8o/kafka/blob/f834be5e73e46805b29df9845bf09be98f91fc09/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java#L78
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
