Mögliche Exception wegen konkurrierendem Zugriff auf Map verhindert

diff --git a/src/main/java/de/juplo/kafka/CounterState.java b/src/main/java/de/juplo/kafka/CounterState.java
index 715a97a..804e247 100644 (file)
--- a/src/main/java/de/juplo/kafka/CounterState.java
+++ b/src/main/java/de/juplo/kafka/CounterState.java
@@ -19,6 +19,6 @@ public class CounterState
 
   public synchronized Map<String, Long> getCounterState()
   {
-    return counterState;
+    return new HashMap<>(counterState);
   }
 }

diff --git a/src/main/java/de/juplo/kafka/CounterStateController.java b/src/main/java/de/juplo/kafka/CounterStateController.java
index 723a8d0..ace87a9 100644 (file)
--- a/src/main/java/de/juplo/kafka/CounterStateController.java
+++ b/src/main/java/de/juplo/kafka/CounterStateController.java
@@ -4,7 +4,6 @@ import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
 
-import java.util.HashMap;
 import java.util.Map;
 
 
@@ -17,6 +16,6 @@ public class CounterStateController
   @GetMapping
   Map<Integer, Map<String, Long>> getAllCounters()
   {
-    return new HashMap<>(consumer.getCounterState());
+    return consumer.getCounterState();
   }
 }