Damian Guy created KAFKA-4851: --------------------------------- Summary: SessionStore.fetch(key) is a performance bottleneck Key: KAFKA-4851 URL: https://issues.apache.org/jira/browse/KAFKA-4851 Project: Kafka Issue Type: Bug Components: streams Affects Versions: 0.10.2.0 Reporter: Damian Guy Assignee: Damian Guy Fix For: 0.11.0.0
When flushing the {{CachingSessionStore}} we need to search for the previous value for a session. This involves searching each open RocksDB segment. The code ends up doing a call {{Segments.segments(0, Long.MAX_VALUE)}} this results in approximately 3 million gets on a {{ConcurrentHashMap}} of which all but 3 of them will be hits. Change this code to restrict the segmentIds to search just to the available set. -- This message was sent by Atlassian JIRA (v6.3.15#6346)