X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Fquery%2FTestData.java;h=610bca04c05892a37641e79eb15ad1b6ca447d7f;hb=2b22a006cc57203406c8589687a6c729ebdbf40c;hp=82f72174ca16b4bac2d3242a23bf3101851accf9;hpb=213321a01c3b53f86eb2dd97c3f6241e9cad9045;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/query/TestData.java b/src/test/java/de/juplo/kafka/wordcount/query/TestData.java
index 82f7217..610bca0 100644
--- a/src/test/java/de/juplo/kafka/wordcount/query/TestData.java
+++ b/src/test/java/de/juplo/kafka/wordcount/query/TestData.java
@@ -42,6 +42,11 @@ class TestData
 
 	private static UserRanking userRankingOf(String json)
 	{
+		if (json == null)
+		{
+			return null;
+		}
+
 		try
 		{
 			return objectMapper.readValue(json, UserRanking.class);