Roman Leventov created KAFKA-9356:
-------------------------------------
Summary: Potential data loss in InMemoryWindowStore and
InMemorySessionStore
Key: KAFKA-9356
URL: https://issues.apache.org/jira/browse/KAFKA-9356
Project: Kafka
Issue Type: Bug
Reporter: Roman Leventov
{{InMemoryWindowStore.put()}} and {{InMemorySessionStore.put()}} call
{{computeIfAbsent()}} method on {{ConcurrentSkipListMap}} objects which opens
up possibility for data loss because
{{ConcurrentSkipListMap.computeIfAbsent()}} is not an atomic operation.
Possible fix: replace {{ConcurrentSkipListMap}}s with {{synchronized[Sorted,
Navigable]Map(new TreeMap<>())}}.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
