Vorlage für den 1. Teil der Summenformel-Übung

[demos/kafka/training] / src / main / java / de / juplo / kafka / AdderResults.java

diff --git a/src/main/java/de/juplo/kafka/AdderResults.java b/src/main/java/de/juplo/kafka/AdderResults.java
index e7f5602..da9f65e 100644 (file)
--- a/src/main/java/de/juplo/kafka/AdderResults.java
+++ b/src/main/java/de/juplo/kafka/AdderResults.java
@@ -15,6 +15,12 @@ public class AdderResults
   {
     Map<String, List<AdderResult>> resultsByUser = this.results.get(partition);
 
+    if (resultsByUser == null)
+    {
+      resultsByUser = new HashMap<>();
+      results.put(partition, resultsByUser);
+    }
+
     List<AdderResult> results = resultsByUser.get(user);
     if (results == null)
     {