[ 
https://issues.apache.org/jira/browse/KAFKA-12804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17346554#comment-17346554
 ] 

A. Sophie Blee-Goldman commented on KAFKA-12804:
------------------------------------------------

Hey [~gorsonw] thanks for the ticket, this class certainly has not been 
optimized much (or at all). I see you applied the "pull request available" 
label to this, can you include the link to your PR in the ticket and assign it 
to yourself if you plan to work on this?

> 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
>            Priority: Minor
>              Labels: performance, pull-request-available
>   Original Estimate: 2h
>  Remaining Estimate: 2h
>
> 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)

Reply via email to