X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;ds=sidebyside;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Ftop10%2FTestData.java;fp=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Ftop10%2FTestData.java;h=cf52c1f8b3eebc0d2c5e6d48e5920eaea7c6297a;hb=8dfd8ee1b26d8d95e95402d9ba2128a113181396;hp=84c81f5d94facd087a166c94f4abca6127587859;hpb=6738dd374575d4d86a966972d2e25661c2ad1523;p=demos%2Fkafka%2Fwordcount

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
--- 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();
 	}