[KAFKA-12219] Potential race condition in InMemoryKeyValueStore

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 2.7.0
• Fix Version/s: 2.8.0, 2.7.1
• Component/s: streams
• Assignee: Dongjin Lee
• Reporter: Dongjin Lee
• Created: 18/Jan/21 08:53
• Updated: 19/Jan/21 19:50
• Resolved: 19/Jan/21 18:35

Description

With KAFKA-8802 (included in 2.4.0 release), ConcurrentSkipListMap in InMemoryKeyValueStore was reverted into TreeMap for performance issues. However, the synchronized keyword for reverseRange, reverseAll methods were omitted when adding the reverse range methods in 2.7, leaving possibility of race condition.

Issue Links

• links to: GitHub Pull Request #9923