top10: 1.2.1 - Fixed possible NPE in `Top10ApplicationIT`

diff --git a/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java b/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
index 84c81f5d94facd087a166c94f4abca6127587859..cf52c1f8b3eebc0d2c5e6d48e5920eaea7c6297a 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
+++ b/src/test/java/de/juplo/kafka/wordcount/top10/TestData.java
@@ -85,7 +85,9 @@ class TestData
 
        static int countMessagesForUser(TestUser user, MultiValueMap<TestUser, TestRanking> messagesForUsers)
        {
-               return messagesForUsers.get(user).size();
+               return messagesForUsers.get(user) == null
+                               ? 0
+                               : messagesForUsers.get(user).size();
        }