[kafka] branch 2.7 updated: KAFKA-12219: Add 'synchronized' keyword to InMemoryKeyValueStore#[reverseRange, reverseAll] (#9923)

[ableegoldman]

This is an automated email from the ASF dual-hosted git repository.

ableegoldman pushed a commit to branch 2.7
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/2.7 by this push:
     new 05db874  KAFKA-12219: Add 'synchronized' keyword to 
InMemoryKeyValueStore#[reverseRange, reverseAll] (#9923)
05db874 is described below

commit 05db87460b0f3b7acdf31b495e0aa889ef260092
Author: Lee Dongjin <dong...@apache.org>
AuthorDate: Wed Jan 20 03:34:46 2021 +0900

    KAFKA-12219: Add 'synchronized' keyword to 
InMemoryKeyValueStore#[reverseRange, reverseAll] (#9923)
    
    Reviewers: Guozhang Wang <wangg...@gmail.com>
---
 .../apache/kafka/streams/state/internals/InMemoryKeyValueStore.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java
 
b/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java
index 31041b9..33968d3 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java
@@ -116,7 +116,7 @@ public class InMemoryKeyValueStore implements 
KeyValueStore<Bytes, byte[]> {
     }
 
     @Override
-    public KeyValueIterator<Bytes, byte[]> reverseRange(final Bytes from, 
final Bytes to) {
+    public synchronized KeyValueIterator<Bytes, byte[]> reverseRange(final 
Bytes from, final Bytes to) {
         return range(from, to, false);
     }
 
@@ -142,7 +142,7 @@ public class InMemoryKeyValueStore implements 
KeyValueStore<Bytes, byte[]> {
     }
 
     @Override
-    public KeyValueIterator<Bytes, byte[]> reverseAll() {
+    public synchronized KeyValueIterator<Bytes, byte[]> reverseAll() {
         return new DelegatingPeekingKeyValueIterator<>(
             name,
             new InMemoryKeyValueIterator(map.keySet(), false));