top10: 1.2.1 - Fixed possible NPE in `Top10ApplicationIT`

[demos/kafka/wordcount] / src / test / java / de / juplo / kafka / wordcount / top10 / TestData.java

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 84c81f5..cf52c1f 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();
        }