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)
